fixes for moving nowait into NewRequest

nats-io · Jun 20, 2024 · 25490e1 · 25490e1
1 parent 00efd84
commit 25490e1
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/server/mqtt.go b/server/mqtt.go
@@ -1563,6 +1563,10 @@ func (jsa *mqttJSA) newRequestEx(kind, subject, cidHash string, hdr int, msg []b
 	if err != nil {
 		return nil, err
 	}
+	if timeout == 0{
+		return nil, err
+	}
+
 	if len(responses) != 1 {
 		return nil, fmt.Errorf("unreachable: invalid number of responses (%d)", len(responses))
 	}
@@ -1719,6 +1723,9 @@ func (jsa *mqttJSA) deleteConsumer(streamName, consName string, noWait bool) (*J
 	if err != nil {
 		return nil, err
 	}
+	if noWait {
+		return nil, nil
+	}
 	cdr := cdri.(*JSApiConsumerDeleteResponse)
 	return cdr, cdr.ToError()
 }