diff --git a/muxers/mplex/src/lib.rs b/muxers/mplex/src/lib.rs index 8b689f0b..37306f52 100644 --- a/muxers/mplex/src/lib.rs +++ b/muxers/mplex/src/lib.rs @@ -495,7 +495,7 @@ where C: AsyncRead + AsyncWrite // just read and wait for the next iteration. match next_data_poll? { Async::Ready(Some(data)) => substream.current_data = data, - Async::Ready(None) | Async::Ready(None) => { + Async::Ready(None) => { substream.remote_open = false; return Ok(Async::Ready(0)); },