Interface Bus

pubsub/bus.go:24–29

Bus is an async event bus that allows subscriptions to behave as a bus themselves. When an event is published, it is sent to all subscribers asynchronously - a subscriber cannot block other subscribers. NOTE: this should probably be in util/event or something (not in provider/event)

//
// NOTE: this should probably be in util/event or something (not in provider/event)
type Bus interface {
	Publisher
	Subscribe() (Subscriber, error)
	Close()
	Done() <-chan struct{}
}

// Subscriber emits events it sees on the channel returned by Events().
// A Clone() of a subscriber will emit all events that have not been emitted