event

Jun 30, 2019

Changes in this version

+ var ErrMuxClosed = errors.New("event: mux closed")

+ type Feed struct

+ func (f *Feed) Send(value interface{}) (nsent int)

+ func (f *Feed) Subscribe(channel interface{}) Subscription

+ type ResubscribeFunc func(context.Context) (Subscription, error)

+ type Subscription interface

+ Err func() <-chan error

+ Unsubscribe func()

+ func NewSubscription(producer func(<-chan struct{}) error) Subscription

+ func Resubscribe(backoffMax time.Duration, fn ResubscribeFunc) Subscription

+ type SubscriptionScope struct

+ func (sc *SubscriptionScope) Close()

+ func (sc *SubscriptionScope) Count() int

+ func (sc *SubscriptionScope) Track(s Subscription) Subscription

+ type TypeMux struct

+ func (mux *TypeMux) Post(ev interface{}) error

+ func (mux *TypeMux) Stop()

+ func (mux *TypeMux) Subscribe(types ...interface{}) *TypeMuxSubscription

+ type TypeMuxEvent struct

+ Data interface{}

+ Time time.Time

+ type TypeMuxSubscription struct

+ func (s *TypeMuxSubscription) Chan() <-chan *TypeMuxEvent

+ func (s *TypeMuxSubscription) Unsubscribe()