From 3ed4db132ce3bed46d38537b5a489b24fbc44655 Mon Sep 17 00:00:00 2001 From: evilsocket Date: Thu, 20 Sep 2018 14:02:56 +0200 Subject: [PATCH] fix: fixed a bug which prevented the first log messages not to be showed by the event.stream module --- session/events.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/session/events.go b/session/events.go index 733d12f9..6de9defa 100644 --- a/session/events.go +++ b/session/events.go @@ -58,6 +58,15 @@ func (p *EventPool) Listen() <-chan Event { p.Lock() defer p.Unlock() l := make(chan Event) + + // make sure, without blocking, the new listener + // will receive all the queued events + go func() { + for _, e := range p.events { + l <- e + } + }() + p.listeners = append(p.listeners, l) return l }