rustfmt some test cases
This commit is contained in:
@@ -346,15 +346,13 @@ async fn stream_error_release_connection_capacity() {
|
||||
let mut should_recv_frames = 2usize;
|
||||
|
||||
let err = body
|
||||
.try_for_each(|bytes| {
|
||||
async move {
|
||||
.try_for_each(|bytes| async move {
|
||||
should_recv_bytes -= bytes.len();
|
||||
should_recv_frames -= 1;
|
||||
if should_recv_bytes == 0 {
|
||||
assert_eq!(should_recv_bytes, 0);
|
||||
}
|
||||
Ok(())
|
||||
}
|
||||
})
|
||||
.await
|
||||
.expect_err("body");
|
||||
|
||||
@@ -39,8 +39,7 @@ async fn recv_push_works() {
|
||||
assert_eq!(resp.status(), StatusCode::NOT_FOUND);
|
||||
};
|
||||
let check_pushed_response = async move {
|
||||
let p = pushed.and_then(|headers| {
|
||||
async move {
|
||||
let p = pushed.and_then(|headers| async move {
|
||||
let (request, response) = headers.into_parts();
|
||||
assert_eq!(request.into_parts().0.method, Method::GET);
|
||||
let resp = response.await.unwrap();
|
||||
@@ -48,7 +47,6 @@ async fn recv_push_works() {
|
||||
let b = util::concat(resp.into_body()).await.unwrap();
|
||||
assert_eq!(b, "promised_data");
|
||||
Ok(())
|
||||
}
|
||||
});
|
||||
let ps: Vec<_> = p.collect().await;
|
||||
assert_eq!(1, ps.len())
|
||||
|
||||
Reference in New Issue
Block a user