pubsub

type Notifier interface {
	Listen(channel string, bufferSize int, warnOnDrop bool) Subscription
}

type Subscription interface {
	NotificationC() <-chan string
	EstablishedC() <-chan struct{}
	Cancel()
}