Versions in this module Expand all Collapse all v1 v1.0.2 Mar 17, 2021 Changes in this version + type PubSub struct + func New() *PubSub + func (ps *PubSub) NumSubscribers() int32 + func (ps *PubSub) Publish(item interface{}) + func (ps *PubSub) Subscribe(subCh chan interface{}, doneCh <-chan struct{}, ...) + type Sub struct