New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
replace Vec with FuturesUnordered #163
Conversation
} | ||
Ok(Async::Ready(None)) => {} | ||
Err(err) => { | ||
warn!(target: "libp2p-swarm", "Error in listener: {:?}", err); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I this this warning should be kept.
self.listeners_upgrade.push(upgrade); | ||
} | ||
Err(err) => { | ||
debug!(target: "libp2p-swarm", "Error in listener upgrade: {:?}", err); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This one as well.
self.dialers.push(dialer); | ||
} | ||
Err(err) => { | ||
debug!(target: "libp2p-swarm", "Error in dialer upgrade: {:?}", err); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Same.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@tomaka added err log
swarm/src/swarm.rs
Outdated
} | ||
Ok(Async::NotReady) => self.to_process.push(to_process), | ||
Err(err) => { | ||
debug!(target: "libp2p-swarm", "Error in processing: {:?}", err); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Same.
Thanks |
This reverts commit 9674744.
No description provided.