conn: delete from pending on close

sourcegraph · Dec 3, 2024 · ccd64f0 · ccd64f0
1 parent 534fd43
commit ccd64f0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/conn.go b/conn.go
@@ -173,8 +173,9 @@ func (c *Conn) close(cause error) error {
 		return ErrClosed
 	}
 
-	for _, call := range c.pending {
+	for id, call := range c.pending {
 		close(call.done)
+		delete(c.pending, id)
 	}
 
 	if cause != nil && cause != io.EOF && cause != io.ErrUnexpectedEOF {