fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-06-22 14:21:33 +00:00
Code Issues Projects Releases Wiki Activity

Similar to #469, consider endpoint while retaining. (#470)

Browse Source
This commit is contained in:
Toralf Wittner
2018-09-10 14:03:38 +02:00
committed by GitHub
parent ec6ec92a79
commit cfdfca1a06
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
muxers/mplex/src/lib.rs
View File

@ -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)
},
};