vbatts/pkg
1
0
Fork 0
Code Pull requests Releases Activity

Remove publisher if no one is listening

Browse source 
Signed-off-by: Michael Crosby <crosbymichael@gmail.com>
This commit is contained in:
Michael Crosby 2015-01-20 11:37:50 -08:00
parent eff8e3294c
commit a96214b8c6
1 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
pubsub/publisher.go
View file

@ -26,6 +26,14 @@ type Publisher struct {
subscribers map[subscriber]struct{} subscribers map[subscriber]struct{}
} }
// Len returns the number of subscribers for the publisher
func (p *Publisher) Len() int {
p.m.RLock()
i := len(p.subscribers)
p.m.RUnlock()
return i
}
// Subscribe adds a new subscriber to the publisher returning the channel. // Subscribe adds a new subscriber to the publisher returning the channel.
func (p *Publisher) Subscribe() chan interface{} { func (p *Publisher) Subscribe() chan interface{} {
ch := make(chan interface{}, p.buffer) ch := make(chan interface{}, p.buffer)