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

Fix handling not consumed request's payload (#367)

Browse source
This commit is contained in:
Nikolay Kim 2024-05-29 18:29:49 +05:00 • committed by GitHub
parent 9c29de14cf
commit 34142e1ae2
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
5 changed files with 43 additions and 33 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;
poll_fn(move |cx| {
if !ready1 {
match pin::Pin::new(&mut fut1).poll(cx) {
Poll::Ready(_) => ready1 = true,
Poll::Pending => (),
}
if !ready1 && pin::Pin::new(&mut fut1).poll(cx).is_ready() {
ready1 = true;
}
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 {
Poll::Ready(())
@ -51,19 +45,11 @@ where
let mut ready2 = false;
poll_fn(move |cx| {
if !ready1 {
match pin::Pin::new(&mut fut1).poll(cx) {
Poll::Ready(Ok(())) => ready1 = true,
Poll::Ready(Err(err)) => return Poll::Ready(Err(err)),
Poll::Pending => (),
}
if !ready1 && pin::Pin::new(&mut fut1).poll(cx)?.is_ready() {
ready1 = true;
}
if !ready2 {
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 !ready2 && pin::Pin::new(&mut fut2).poll(cx)?.is_ready() {
ready2 = true;
}
if ready1 && ready2 {
Poll::Ready(Ok(()))