Revert "use pubsub instead of filenotify to follow json logs"
This reverts commit b1594c59f5e0d1ac898eacde8d91b1ba33c2b626. Signed-off-by: Brian Goff <cpuguy83@gmail.com>
This commit is contained in:
parent
e901b002ac
commit
d932514e7e
1 changed files with 2 additions and 4 deletions
|
@ -56,10 +56,8 @@ func (p *Publisher) SubscribeTopic(topic topicFunc) chan interface{} {
|
|||
// Evict removes the specified subscriber from receiving any more messages.
|
||||
func (p *Publisher) Evict(sub chan interface{}) {
|
||||
p.m.Lock()
|
||||
if _, ok := p.subscribers[sub]; ok {
|
||||
delete(p.subscribers, sub)
|
||||
close(sub)
|
||||
}
|
||||
delete(p.subscribers, sub)
|
||||
close(sub)
|
||||
p.m.Unlock()
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in a new issue