From ffe5b6272a9bd2a7aed78629e45e2267822d8756 Mon Sep 17 00:00:00 2001 From: Tanguy Date: Fri, 3 Mar 2023 15:33:42 +0100 Subject: [PATCH] ugly test --- libp2p/muxers/mplex/mplex.nim | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/libp2p/muxers/mplex/mplex.nim b/libp2p/muxers/mplex/mplex.nim index 68304f8a5..9d3a31015 100644 --- a/libp2p/muxers/mplex/mplex.nim +++ b/libp2p/muxers/mplex/mplex.nim @@ -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: