Versions in this module Expand all Collapse all v1 v1.1.2 Sep 16, 2021 Changes in this version + var ErrDuplicateSubscribe = errors.New("event: subscribe duplicate type") + var ErrMuxClosed = errors.New("event: mux closed") + type Dispatcher struct + func NewDispatcher() *Dispatcher + func (d *Dispatcher) Post(ev interface{}) error + func (d *Dispatcher) Stop() + func (d *Dispatcher) Subscribe(types ...interface{}) (*Subscription, error) + type NewMinedBlockEvent struct + Block types.Block + type Subscription struct + func (s *Subscription) Chan() <-chan *TypeMuxEvent + func (s *Subscription) Closed() bool + func (s *Subscription) Unsubscribe() + type TypeMuxEvent struct + Data interface{} + Time time.Time
Go to main page