Only appened response status if request.wait()

streadway · Mar 8, 2019 · ab4d0f0 · ab4d0f0
1 parent 2044042
commit ab4d0f0
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/channel.go b/channel.go
@@ -183,13 +183,13 @@ func (ch *Channel) call(ctx context.Context, req message, res ...message) error
 		return err
 	}
 
-	var status uint32
+	if req.wait() {
+		var status uint32
 
-	ch.responsesM.Lock()
-	ch.responses = append(ch.responses, &status)
-	ch.responsesM.Unlock()
+		ch.responsesM.Lock()
+		ch.responses = append(ch.responses, &status)
+		ch.responsesM.Unlock()
 
-	if req.wait() {
 		select {
 		case <-ctx.Done():
 			atomic.StoreUint32(&status, 1)