event

Apr 14, 2017

Changes in this version

+ 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

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

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

+ Err func() <-chan error

+ type SubscriptionScope struct

+ func (sc *SubscriptionScope) Close()

+ func (sc *SubscriptionScope) Count() int

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

+ type TypeMuxEvent struct

+ Data interface{}

+ Time time.Time

+ type TypeMuxSubscription struct

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

+ func (s *TypeMuxSubscription) Unsubscribe()

May 24, 2016

Changes in this version

+ type Event struct

+ Data interface{}

+ Time time.Time

Dec 24, 2014

Changes in this version

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

+ type Subscription interface

+ Chan func() <-chan interface{}

+ Unsubscribe func()

+ type TypeMux struct

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

+ func (mux *TypeMux) Stop()

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