From 9eb9ccac19066e247263b17231f6d3eb12104c9f Mon Sep 17 00:00:00 2001 From: Diego Date: Thu, 25 Jan 2024 14:36:39 +0100 Subject: [PATCH] remove messageAvailable --- libp2p/protocols/pubsub/pubsubpeer.nim | 2 -- 1 file changed, 2 deletions(-) diff --git a/libp2p/protocols/pubsub/pubsubpeer.nim b/libp2p/protocols/pubsub/pubsubpeer.nim index 22265ee3a4..a6c25a288f 100644 --- a/libp2p/protocols/pubsub/pubsubpeer.nim +++ b/libp2p/protocols/pubsub/pubsubpeer.nim @@ -58,7 +58,6 @@ type RpcMessageQueue* = ref object priorityQueue: AsyncQueue[seq[byte]] nonPriorityQueue: AsyncQueue[seq[byte]] - messageAvailableEvent: AsyncEvent queueProcessingTask: Future[void] isProcessing: bool # Flag to indicate if processing is underway @@ -405,7 +404,6 @@ proc new(T: typedesc[RpcMessageQueue]): T = return T( priorityQueue: newAsyncQueue[seq[byte]](), nonPriorityQueue: newAsyncQueue[seq[byte]](), - messageAvailableEvent: newAsyncEvent(), ) proc new*(