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