From 5e205e2a20e0dd4ae9abf32d82ef5025398ee769 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 3fc02f1a76..9c951caf6c 100644 --- a/libp2p/protocols/pubsub/pubsubpeer.nim +++ b/libp2p/protocols/pubsub/pubsubpeer.nim @@ -59,7 +59,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 @@ -406,7 +405,6 @@ proc new(T: typedesc[RpcMessageQueue]): T = return T( priorityQueue: newAsyncQueue[seq[byte]](), nonPriorityQueue: newAsyncQueue[seq[byte]](), - messageAvailableEvent: newAsyncEvent(), ) proc new*(