From 00d2713037ab136efefcc150eddc572f8995f34c Mon Sep 17 00:00:00 2001 From: Sean McArthur Date: Wed, 29 Jan 2020 15:21:11 -0800 Subject: [PATCH] rustfmt some test cases --- tests/h2-tests/tests/flow_control.rs | 14 ++++++-------- tests/h2-tests/tests/push_promise.rs | 18 ++++++++---------- 2 files changed, 14 insertions(+), 18 deletions(-) diff --git a/tests/h2-tests/tests/flow_control.rs b/tests/h2-tests/tests/flow_control.rs index 730cd81f4..f03404130 100644 --- a/tests/h2-tests/tests/flow_control.rs +++ b/tests/h2-tests/tests/flow_control.rs @@ -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 { - should_recv_bytes -= bytes.len(); - should_recv_frames -= 1; - if should_recv_bytes == 0 { - assert_eq!(should_recv_bytes, 0); - } - Ok(()) + .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"); diff --git a/tests/h2-tests/tests/push_promise.rs b/tests/h2-tests/tests/push_promise.rs index dfdf8eb44..f786a72b7 100644 --- a/tests/h2-tests/tests/push_promise.rs +++ b/tests/h2-tests/tests/push_promise.rs @@ -39,16 +39,14 @@ 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 (request, response) = headers.into_parts(); - assert_eq!(request.into_parts().0.method, Method::GET); - let resp = response.await.unwrap(); - assert_eq!(resp.status(), StatusCode::OK); - let b = util::concat(resp.into_body()).await.unwrap(); - assert_eq!(b, "promised_data"); - Ok(()) - } + 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(); + assert_eq!(resp.status(), StatusCode::OK); + 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())