status-im/nim-libp2p
2
0
Fork 0
mirror of https://github.com/status-im/nim-libp2p.git synced 2025-02-21 09:08:17 +00:00
Code Issues Projects Releases Wiki Activity

remove messageAvailable

Browse Source
This commit is contained in:
Diego 2024-01-25 14:36:39 +01:00
parent 6d9cbf4bec
commit 9eb9ccac19
No known key found for this signature in database
GPG Key ID: C9DAC9BF68D1F806
1 changed files with 0 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
libp2p/protocols/pubsub/pubsubpeer.nim
View File

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