fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-06-24 07:11:38 +00:00
Code Issues Projects Releases Wiki Activity

Use loop to poll FuturesUnordered after push. (#198)

Browse Source 
Fixes #190.
This commit is contained in:
Toralf Wittner
2018-05-21 16:27:03 +02:00
committed by GitHub
parent 3dacc9009e
commit 250af629ee
1 changed files with 12 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
core/src/swarm.rs
View File

@ -268,16 +268,19 @@ where
Ok(Async::NotReady) => {} Ok(Async::NotReady) => {}
}; };
match self.listeners.poll() { loop {
Ok(Async::Ready(Some((Some(upgrade), remaining)))) => { match self.listeners.poll() {
trace!("Swarm received new connection on listener socket"); Ok(Async::Ready(Some((Some(upgrade), remaining)))) => {
self.listeners_upgrade.push(upgrade); trace!("Swarm received new connection on listener socket");
self.listeners.push(remaining.into_future()); self.listeners_upgrade.push(upgrade);
self.listeners.push(remaining.into_future());
}
Err((err, _)) => {
warn!("Error in listener: {:?}", err);
break
}
_ => break
} }
Err((err, _)) => {
warn!("Error in listener: {:?}", err);
}
_ => {}
} }
match self.listeners_upgrade.poll() { match self.listeners_upgrade.poll() {