remove messageAvailable

vacp2p · Jan 30, 2024 · 9eb9cca · 9eb9cca
1 parent 6d9cbf4
commit 9eb9cca
Showing 1 changed file with 0 additions and 2 deletions.
diff --git 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*(