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

Update more crates to futures-0.3 (#1312)

Browse Source
This commit is contained in:
Toralf Wittner
2019-11-19 11:18:16 +01:00
committed by GitHub
parent be73b90345
commit 02c5f34fc0
15 changed files with 25 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/nodes/node.rs
View File

@ -133,7 +133,7 @@ where
/// Destroys all outbound streams and returns the corresponding user data.
pub fn cancel_outgoing(&mut self) -> Vec<TUserData> {
let mut out = Vec::with_capacity(self.outbound_substreams.len());
for (user_data, outbound) in self.outbound_substreams.drain() {
for (user_data, outbound) in self.outbound_substreams.drain(..) {
out.push(user_data);
self.muxer.destroy_outbound(outbound);
}
@ -201,7 +201,7 @@ where
// The substreams that were produced will continue to work, as the muxer is held in an Arc.
// However we will no longer process any further inbound or outbound substream, and we
// therefore close everything.
for (_, outbound) in self.outbound_substreams.drain() {
for (_, outbound) in self.outbound_substreams.drain(..) {
self.muxer.destroy_outbound(outbound);
}
}