mirrors/ntex
1
0
Fork 0
mirror of https://github.com/ntex-rs/ntex.git synced 2025-04-05 05:47:40 +03:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Nikolay Kim 2024-05-29 18:16:42 +05:00
parent 5804165d9a
commit a02865ab4b
1 changed files with 8 additions and 22 deletions
Download patch file Download diff file Expand all files Collapse all files

30
ntex-service/src/util.rs
View file

@ -14,17 +14,11 @@ where
let mut ready2 = false; let mut ready2 = false;
poll_fn(move |cx| { poll_fn(move |cx| {
if !ready1 { if !ready1 && pin::Pin::new(&mut fut1).poll(cx).is_ready() {
match pin::Pin::new(&mut fut1).poll(cx) { ready1 = true;
Poll::Ready(_) => ready1 = true,
Poll::Pending => (),
}
}
if !ready2 {
match pin::Pin::new(&mut fut2).poll(cx) {
Poll::Ready(_) => ready2 = true,
Poll::Pending => (),
} }
if !ready2 && pin::Pin::new(&mut fut2).poll(cx).is_ready() {
ready2 = true
} }
if ready1 && ready2 { if ready1 && ready2 {
Poll::Ready(()) Poll::Ready(())
@ -51,19 +45,11 @@ where
let mut ready2 = false; let mut ready2 = false;
poll_fn(move |cx| { poll_fn(move |cx| {
if !ready1 { if !ready1 && pin::Pin::new(&mut fut1).poll(cx)?.is_ready() {
match pin::Pin::new(&mut fut1).poll(cx) { ready1 = true;
Poll::Ready(Ok(())) => ready1 = true,
Poll::Ready(Err(err)) => return Poll::Ready(Err(err)),
Poll::Pending => (),
} }
} if !ready2 && pin::Pin::new(&mut fut2).poll(cx)?.is_ready() {
if !ready2 { ready2 = true;
match pin::Pin::new(&mut fut2).poll(cx) {
Poll::Ready(Ok(())) => ready2 = true,
Poll::Ready(Err(err)) => return Poll::Ready(Err(err)),
Poll::Pending => (),
};
} }
if ready1 && ready2 { if ready1 && ready2 {
Poll::Ready(Ok(())) Poll::Ready(Ok(()))