Versions in this module Expand all Collapse all v0 v0.2.3 Feb 27, 2015 v0.2.2 Feb 27, 2015 Changes in this version + type PubSub struct + func New(capacity int) *PubSub + func (ps *PubSub) AddSub(ch chan interface{}, topics ...string) + func (ps *PubSub) AddSubOnceEach(ch chan interface{}, topics ...string) + func (ps *PubSub) Close(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) SubOnceEach(topics ...string) chan interface{} + func (ps *PubSub) Unsub(ch chan interface{}, topics ...string)