From eb0ca12ec691556f0c6cde4425031147b85ec2d1 Mon Sep 17 00:00:00 2001 From: evilsocket Date: Mon, 19 Mar 2018 11:44:30 +0100 Subject: [PATCH] fix: increased events backlog for events.stream listener channels (fixes #187) --- session/events.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/session/events.go b/session/events.go index 24fe1899..9fe075ab 100644 --- a/session/events.go +++ b/session/events.go @@ -57,7 +57,7 @@ func NewEventPool(debug bool, silent bool) *EventPool { func (p *EventPool) Listen() <-chan Event { p.Lock() defer p.Unlock() - l := make(chan Event, 1) + l := make(chan Event, 255) p.listeners = append(p.listeners, l) return l } @@ -86,6 +86,7 @@ func (p *EventPool) Add(tag string, data interface{}) { select { case l <- e: default: + fmt.Fprintf(os.Stderr, "Message not sent!\n") } } }