remove messageAvailable

vacp2p · Jan 26, 2024 · c70f88f · c70f88f
1 parent 3ee1eb4
commit c70f88f
Showing 1 changed file with 0 additions and 2 deletions.
diff --git 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
 
@@ -412,7 +411,6 @@ proc new(T: typedesc[RpcMessageQueue]): T =
   return T(
     priorityQueue: newAsyncQueue[seq[byte]](),
     nonPriorityQueue: newAsyncQueue[seq[byte]](),
-    messageAvailableEvent: newAsyncEvent(),
   )
 
 proc new*(