Method SubscribeWithErr

coderd/database/pubsub/pubsub.go:249–251

(event string, listener ListenerWithErr)

}

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

func (p *PGPubsub) subscribeQueue(event string, newQ *MsgQueue) (cancel func(), err error) {
	defer func() {