diff --git a/client.go b/client.go
index 91402c9..d338fdc 100644
--- a/client.go
+++ b/client.go
@@ -465,6 +465,10 @@ func (c *ClientConn) mainLoop() {
 
 		c.config.ServerMessageCh <- parsedMsg
 	}
+
+	if c.config.ServerMessageCh != nil {
+		close(c.config.ServerMessageCh)
+	}
 }
 
 func (c *ClientConn) readErrorReason() string {