rwf2
/
Rocket
mirror of https://github.com/rwf2/Rocket.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update hyper to '=0.13.0-alpha.1'.

This commit is contained in:
Jacob Pratt 2019-09-04 15:05:55 -04:00 committed by Sergio Benitez
parent baa2ed27f3
commit 1f90a9b6d1
2 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/http/Cargo.toml
View File

@ -22,7 +22,7 @@ private-cookies = ["cookie/private", "cookie/key-expansion"]
[dependencies]
smallvec = "1.0"
percent-encoding = "1"
hyper = { git = "https://github.com/hyperium/hyper", rev = "049b513", default-features = false, features = ["runtime"] }
hyper = { version = "=0.13.0-alpha.1", default-features = false, features = ["runtime"] }
http = "0.1.17"
mime = "0.3.13"
time = "0.2.11"

6
core/lib/src/rocket.rs
View File

@ -151,8 +151,7 @@ impl Rocket {
let mut stream = body.into_chunk_stream(4096);
while let Some(next) = stream.next().await {
futures::future::poll_fn(|cx| sender.poll_ready(cx)).await.expect("TODO.async client gone?");
sender.send_data(next?).expect("send chunk");
sender.send_data(next?).await.expect("TODO.async client gone?");
}
}
Some(Body::Chunked(body, chunk_size)) => {
@ -163,8 +162,7 @@ impl Rocket {
let mut stream = body.into_chunk_stream(chunk_size.try_into().expect("u64 -> usize overflow"));
while let Some(next) = stream.next().await {
futures::future::poll_fn(|cx| sender.poll_ready(cx)).await.expect("TODO.async client gone?");
sender.send_data(next?).expect("send chunk");
sender.send_data(next?).await.expect("TODO.async client gone?");
}
}
};