status-im
/
nim-libp2p
mirror of https://github.com/status-im/nim-libp2p.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

revert yamux change

This commit is contained in:
Diego 2024-08-12 12:52:03 +02:00
parent 188b119d2e
commit e21b0e4d99
No known key found for this signature in database
GPG Key ID: C9DAC9BF68D1F806
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
libp2p/muxers/yamux/yamux.nim
View File

@ -12,7 +12,6 @@
import sequtils, std/[tables] import sequtils, std/[tables]
import chronos, chronicles, metrics, stew/[endians2, byteutils, objects] import chronos, chronicles, metrics, stew/[endians2, byteutils, objects]
import ../muxer, ../../stream/connection import ../muxer, ../../stream/connection
import ../../utils/future
export muxer export muxer
@ -281,7 +280,7 @@ method readOnce*(
if channel.recvQueue.len == 0: if channel.recvQueue.len == 0:
channel.receivedData.clear() channel.receivedData.clear()
try: # https://github.com/status-im/nim-chronos/issues/516 try: # https://github.com/status-im/nim-chronos/issues/516
discard await raceCancel(@[channel.closedRemotely.wait(), channel.receivedData.wait()]) discard await race(channel.closedRemotely.wait(), channel.receivedData.wait())
except ValueError: except ValueError:
raiseAssert("Futures list is not empty") raiseAssert("Futures list is not empty")
if channel.closedRemotely.isSet() and channel.recvQueue.len == 0: if channel.closedRemotely.isSet() and channel.recvQueue.len == 0: