Function NewMsgQueue

coderd/database/pubsub/pubsub.go:77–89

(ctx context.Context, l Listener, le ListenerWithErr)

}

func NewMsgQueue(ctx context.Context, l Listener, le ListenerWithErr) *MsgQueue {
	if l == nil && le == nil {
		panic("l or le must be non-nil")
	}
	q := &MsgQueue{
		ctx:  ctx,
		cond: sync.NewCond(&sync.Mutex{}),
		l:    l,
		le:   le,
	}
	go q.run()
	return q
}

func (q *MsgQueue) run() {
	for {