fix: fixed the leak of a channel if the events stream module was restarted

This commit is contained in:
evilsocket 2018-05-12 12:36:47 +02:00
commit b75694f540
No known key found for this signature in database
GPG key ID: 1564D7F30393A456

View file

@ -148,6 +148,8 @@ func (s *EventsStream) Start() error {
return s.SetRunning(true, func() { return s.SetRunning(true, func() {
s.eventListener = s.Session.Events.Listen() s.eventListener = s.Session.Events.Listen()
defer s.Session.Events.Unlisten(s.eventListener)
for { for {
var e session.Event var e session.Event
select { select {