status-im/nim-libp2p
2
0
Fork 0
mirror of https://github.com/status-im/nim-libp2p.git synced 2025-02-26 19:40:32 +00:00
Code Issues Projects Releases Wiki Activity

ugly test

Browse Source
This commit is contained in:
Tanguy 2023-03-03 15:33:42 +01:00
parent 45ca569040
commit ffe5b6272a
No known key found for this signature in database
GPG Key ID: 7DD8EC6B6CE6C45E
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
libp2p/muxers/mplex/mplex.nim
View File

@ -179,7 +179,7 @@ method handle*(m: Mplex) {.async, gcsafe.} =
trace "pushing data to channel", m, channel, len = data.len
try:
let start = Moment.now()
await channel.pushData(data)
discard channel.pushData(data)
let delay = Moment.now() - start
if delay > 1.seconds:
@ -192,10 +192,10 @@ method handle*(m: Mplex) {.async, gcsafe.} =
discard # Ignore message, same as if `cleanupChann` had completed.
of MessageType.CloseIn, MessageType.CloseOut:
await channel.pushEof()
discard channel.pushEof()
of MessageType.ResetIn, MessageType.ResetOut:
channel.remoteReset = true
await channel.reset()
discard channel.reset()
except CancelledError:
debug "Unexpected cancellation in mplex handler", m
except LPStreamEOFError as exc: