diff --git a/libp2p/muxers/mplex/mplex.nim b/libp2p/muxers/mplex/mplex.nim index eae4bd7..a86c8be 100644 --- a/libp2p/muxers/mplex/mplex.nim +++ b/libp2p/muxers/mplex/mplex.nim @@ -57,6 +57,7 @@ method handle*(m: Mplex) {.async, gcsafe.} = while not m.connection.closed: let msg = await m.connection.readMsg() if msg.isNone: + # TODO: allow poll with timeout to avoid using `sleepAsync` await sleepAsync(10.millis) continue