pubsubchannel

Nov 27, 2019

Changes in this version

+ type PubSubChannel struct

+ func New(inboxSize int) *PubSubChannel

+ func (psc *PubSubChannel) Close()

+ func (psc *PubSubChannel) NumSubscriptions() int

+ func (psc *PubSubChannel) Publish(msg interface{})

+ func (psc *PubSubChannel) Subscribe() *Subscription

+ type Subscription struct

+ func (sub *Subscription) ID() string

+ func (sub *Subscription) IsClosed() bool

+ func (sub *Subscription) MessageCount() int

+ func (sub *Subscription) Pending() int64

+ func (sub *Subscription) ReceiveChannel() <-chan interface{}

+ func (sub *Subscription) Unsubscribe()