From ed70a576a1773a29f313b96bb4a80dafd0cac0c0 Mon Sep 17 00:00:00 2001 From: Tanguy Date: Mon, 6 Mar 2023 12:24:46 +0100 Subject: [PATCH] Revert "ugly test" This reverts commit ffe5b6272a9bd2a7aed78629e45e2267822d8756. --- 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 9d3a31015..68304f8a5 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() - discard channel.pushData(data) + await 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: - discard channel.pushEof() + await channel.pushEof() of MessageType.ResetIn, MessageType.ResetOut: channel.remoteReset = true - discard channel.reset() + await channel.reset() except CancelledError: debug "Unexpected cancellation in mplex handler", m except LPStreamEOFError as exc: