stop the timer when the session's run loop returns

internal/utils/timer.go

@@ -46,3 +46,8 @@ func (t *Timer) Reset(deadline time.Time) {
 func (t *Timer) SetRead() {
 	t.read = true
 }
+
+// Stop stops the timer
+func (t *Timer) Stop() {
+	t.t.Stop()
+}

internal/utils/timer_test.go

@@ -77,4 +77,11 @@ var _ = Describe("Timer", func() {
 		Eventually(t.Chan()).Should(Receive())
 		Consistently(t.Chan()).ShouldNot(Receive())
 	})
+
+	It("stops", func() {
+		t := NewTimer()
+		t.Reset(time.Now().Add(50 * time.Millisecond))
+		t.Stop()
+		Consistently(t.Chan()).ShouldNot(Receive())
+	})
 })

session.go

@@ -605,6 +605,7 @@ runLoop:
 	s.logger.Infof("Connection %s closed.", s.logID)
 	s.cryptoStreamHandler.Close()
 	s.sendQueue.Close()
+	s.timer.Stop()
 	return closeErr.err
 }