event

Jul 25, 2023

Changes in this version

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

type Subscription

+ func ResubscribeErr(backoffMax time.Duration, fn ResubscribeErrFunc) Subscription

Aug 3, 2022

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) Closed() bool

+ func (s *TypeMuxSubscription) Unsubscribe()