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*(