Versions in this module Expand all Collapse all v1 v1.1.21 Jul 5, 2021 Changes in this version + type PubSub struct + func NewPubSub(capacity int) *PubSub + func (ps *PubSub) AddSub(ch chan interface{}, topics ...string) + func (ps *PubSub) Close(topics ...string) + func (ps *PubSub) FIFOPub(msg interface{}, topics ...string) + func (ps *PubSub) Pub(msg interface{}, topics ...string) + func (ps *PubSub) Shutdown() + func (ps *PubSub) Sub(topics ...string) chan interface{} + func (ps *PubSub) SubOnce(topics ...string) chan interface{} + func (ps *PubSub) TryPub(msg interface{}, topics ...string) + func (ps *PubSub) Unsub(ch chan interface{}, topics ...string)
Go to main page