Method
doPublishAsync
(handler *eventHandler, topic string, args ...interface{})
Source from the content-addressed store, hash-verified
| 177 | } |
| 178 | |
| 179 | func (bus *ChainBus) doPublishAsync(handler *eventHandler, topic string, args ...interface{}) { |
| 180 | defer bus.wg.Done() |
| 181 | if handler.transactional { |
| 182 | defer handler.Unlock() |
| 183 | } |
| 184 | bus.doPublish(handler, topic, args...) |
| 185 | } |
| 186 | |
| 187 | func (bus *ChainBus) removeHandler(topic string, idx int) { |
| 188 | if _, ok := bus.handlers[topic]; !ok { |
Tested by
no test coverage detected