safe-async/foxtrot
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Allow spurious polling of sockets

Browse source
This commit is contained in:
Aode (Lion) 2022-03-06 12:30:23 -06:00
parent 4f17580ddd
commit 4c1b9730f8
1 changed files with 12 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
src/io.rs
View file

@ -409,7 +409,10 @@ impl Future for BindTcpListener {
Ok(builder) => {
let builder = match Arc::try_unwrap(builder) {
Ok(builder) => builder,
Err(_) => unreachable!("Should never hold the inner Arc more than once"),
Err(arc) => {
this.io = Some(arc);
return Poll::Pending;
}
};
match builder.try_finish() {
@ -446,7 +449,10 @@ impl Future for BindUdpSocket {
Ok(builder) => {
let builder = match Arc::try_unwrap(builder) {
Ok(builder) => builder,
Err(_) => unreachable!("Should never hold the inner Arc more than once"),
Err(arc) => {
this.io = Some(arc);
return Poll::Pending;
}
};
match builder.try_finish() {
@ -483,7 +489,10 @@ impl Future for Connect {
Ok(builder) => {
let builder = match Arc::try_unwrap(builder) {
Ok(builder) => builder,
Err(_) => unreachable!("Should never hold the inner Arc more than once"),
Err(arc) => {
this.io = Some(arc);
return Poll::Pending;
}
};
match builder.try_finish() {