From cfdfca1a06fb2deb9ebcc15a63d715ebddb23bd0 Mon Sep 17 00:00:00 2001 From: Toralf Wittner Date: Mon, 10 Sep 2018 14:03:38 +0200 Subject: [PATCH] Similar to #469, consider endpoint while retaining. (#470) --- muxers/mplex/src/lib.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/muxers/mplex/src/lib.rs b/muxers/mplex/src/lib.rs index 708f85f6..ba47444e 100644 --- a/muxers/mplex/src/lib.rs +++ b/muxers/mplex/src/lib.rs @@ -390,7 +390,9 @@ where C: AsyncRead + AsyncWrite }, Err(err) => { debug!("Failed to open outbound substream {}", substream.num); - inner.buffer.retain(|elem| elem.substream_id() != substream.num); + inner.buffer.retain(|elem| { + elem.substream_id() != substream.num || elem.endpoint() == Some(Endpoint::Dialer) + }); return Err(err) }, };