diff --git a/modules/events_stream.go b/modules/events_stream.go
index 6c5597f8..c3a7b161 100644
--- a/modules/events_stream.go
+++ b/modules/events_stream.go
@@ -148,6 +148,8 @@ func (s *EventsStream) Start() error {
 
 	return s.SetRunning(true, func() {
 		s.eventListener = s.Session.Events.Listen()
+		defer s.Session.Events.Unlisten(s.eventListener)
+
 		for {
 			var e session.Event
 			select {