Struct MemoryPubsub

coderd/database/pubsub/pubsub_memory.go:27–30

MemoryPubsub is an in-memory Pubsub implementation. It's an exported type so that our test code can do type checks.

// MemoryPubsub is an in-memory Pubsub implementation.  It's an exported type so that our test code can do type
// checks.
type MemoryPubsub struct {
	mut       sync.RWMutex
	listeners map[string]map[uuid.UUID]genericListener
}

func (m *MemoryPubsub) Subscribe(event string, listener Listener) (cancel func(), err error) {
	return m.subscribeGeneric(event, genericListener{l: listener})