Versions in this module Expand all Collapse all v1 v1.0.2 Aug 21, 2020 Changes in this version + func Publish(event interface{}) + func Unsubscribe(sub *Subscription) + type EventStream struct + func (es *EventStream) Subscribe(fn func(evt interface{})) *Subscription + func (ps *EventStream) Publish(evt interface{}) + func (ps *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