Method Subscribe

coderd/database/pubsub/pubsub.go:245–247

Subscribe calls the listener when an event matching the name is received.

(event string, listener Listener)

// Subscribe calls the listener when an event matching the name is received.
func (p *PGPubsub) Subscribe(event string, listener Listener) (cancel func(), err error) {
	return p.subscribeQueue(event, NewMsgQueue(context.Background(), listener, nil))
}

func (p *PGPubsub) SubscribeWithErr(event string, listener ListenerWithErr) (cancel func(), err error) {
	return p.subscribeQueue(event, NewMsgQueue(context.Background(), nil, listener))