From df8e0a0a97de7a31d34b53a0d3a1c1403ee637cd Mon Sep 17 00:00:00 2001 From: Lucio Franco Date: Sat, 21 Sep 2019 10:23:46 -0600 Subject: [PATCH] fmt --- tonic-interop/src/bin/server.rs | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/tonic-interop/src/bin/server.rs b/tonic-interop/src/bin/server.rs index 7c8a748..1b46f34 100644 --- a/tonic-interop/src/bin/server.rs +++ b/tonic-interop/src/bin/server.rs @@ -3,9 +3,9 @@ use tonic::Server; use tonic_interop::{server, MergeTrailers}; // TODO: move GrpcService out of client since it can be used for the // server too. -use tonic::client::GrpcService; -use tonic::body::BoxBody; use http::header::HeaderName; +use tonic::body::BoxBody; +use tonic::client::GrpcService; #[derive(StructOpt)] struct Opts { @@ -32,7 +32,10 @@ async fn main() -> std::result::Result<(), Box> { } builder.interceptor_fn(|svc, req| { - let echo_header = req.headers().get("x-grpc-test-echo-initial").map(Clone::clone); + let echo_header = req + .headers() + .get("x-grpc-test-echo-initial") + .map(Clone::clone); let echo_trailer = req .headers() @@ -46,10 +49,13 @@ async fn main() -> std::result::Result<(), Box> { let mut res = call.await?; if let Some(echo_header) = echo_header { - res.headers_mut().insert("x-grpc-test-echo-initial", echo_header); + res.headers_mut() + .insert("x-grpc-test-echo-initial", echo_header); } - Ok(res.map(|b| MergeTrailers::new(b, echo_trailer)).map(BoxBody::new)) + Ok(res + .map(|b| MergeTrailers::new(b, echo_trailer)) + .map(BoxBody::new)) } });