Function New

chainbus/bus.go:68–75

New returns new ChainBus with empty handlers.

()

// New returns new ChainBus with empty handlers.
func New() Bus {
	b := &ChainBus{
		handlers: make(map[string][]*eventHandler),
		lock:     sync.Mutex{},
		wg:       sync.WaitGroup{},
	}
	return b
}

// doSubscribe handles the subscription logic and is utilized by the public Subscribe functions.
func (bus *ChainBus) doSubscribe(topic string, fn interface{}, handler *eventHandler) error {