Merge pull request #422 from tigerlee/master

Avoid to block thread while write to a nil channel
quickfixgo · May 8, 2023 · 199c332 · 199c332
2 parents 07872e7 + 3ce9479
commit 199c332
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/session.go b/session.go
@@ -367,6 +367,11 @@ func (s *session) EnqueueBytesAndSend(msg []byte) {
 }
 
 func (s *session) sendBytes(msg []byte) {
+	if s.messageOut == nil {
+		s.log.OnEventf("Failed to send: disconnected")
+		return
+	}
+
 	s.log.OnOutgoing(msg)
 	s.messageOut <- msg
 	s.stateTimer.Reset(s.HeartBtInt)