use put instead of putNoWait

vacp2p · Jan 30, 2024 · 6d9cbf4 · 6d9cbf4
1 parent 36d9ec7
commit 6d9cbf4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/libp2p/protocols/pubsub/pubsubpeer.nim b/libp2p/protocols/pubsub/pubsubpeer.nim
@@ -264,11 +264,11 @@ proc sendEncoded*(p: PubSubPeer, msg: seq[byte], isHighPriority: bool = false) {
     return
 
   if isHighPriority:
-    p.rpcmessagequeue.priorityQueue.putNoWait(msg)
+    await p.rpcmessagequeue.priorityQueue.put(msg)
     when defined(libp2p_expensive_metrics):
       libp2p_gossipsub_priority_queue_size.inc(labelValues = [$p.peerId])
   else:
-    p.rpcmessagequeue.nonPriorityQueue.putNoWait(msg)
+    await p.rpcmessagequeue.nonPriorityQueue.put(msg)
     when defined(libp2p_expensive_metrics):
       libp2p_gossipsub_non_priority_queue_size.inc(labelValues = [$p.peerId])
   trace "message queued", p, msg = shortLog(msg)