fix: connection reader block

rabbitmq · Sep 27, 2023 · 9a861ae · 9a861ae
1 parent 654ac24
commit 9a861ae
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/connection.go b/connection.go
@@ -862,13 +862,14 @@ func (c *Connection) call(req message, res ...message) error {
 		}
 	}
 
-	msg, ok := <-c.rpc
-	if !ok {
-		err, errorsChanIsOpen := <-c.errors
-		if !errorsChanIsOpen {
-			return ErrClosed
+	var msg message
+	select {
+	case e, ok := <-c.errors:
+		if ok {
+			return e
 		}
-		return err
+		return ErrClosed
+	case msg = <-c.rpc:
 	}
 
 	// Try to match one of the result types