ClientConn - avoid readThread() trying accessing an invalid channel

bronze1man · Jun 6, 2022 · 51b894d · 51b894d
1 parent 41b373c
commit 51b894d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/clientConn.go b/clientConn.go
@@ -30,7 +30,6 @@ type ClientConn struct {
 func (c *ClientConn) Close() error {
 	c.lock.Lock()
 	defer c.lock.Unlock()
-	close(c.responseChan)
 	c.lastError = io.ErrClosedPipe
 
 	return c.conn.Close()
@@ -174,6 +173,8 @@ func (c *ClientConn) UnregisterEvent(name string) (err error) {
 }
 
 func (c *ClientConn) readThread() {
+	defer close(c.responseChan)
+
 	for {
 		outMsg, err := readSegment(c.conn)
 		if err != nil {