Versions in this module Expand all Collapse all v0 v0.0.1 Oct 25, 2020 Changes in this version + func Publish(event interface{}) + func PublishUnsafe(evt interface{}) + func Unsubscribe(sub *Subscription) + type EventStream struct + func (es *EventStream) Publish(evt interface{}) + func (es *EventStream) PublishUnsafe(evt interface{}) + func (es *EventStream) Subscribe(fn func(evt interface{})) *Subscription + func (es *EventStream) Unsubscribe(sub *Subscription) + type Predicate func(evt interface{}) bool + type Subscription struct + func Subscribe(fn func(evt interface{})) *Subscription + func (s *Subscription) WithPredicate(p Predicate) *Subscription
Go to main page