31         pub fn call<B: Body>(self, req: http::Request<B>) -> http::Request<B> {  in client_enabled_server_enabled()
38             assert_eq!(req.headers().get("grpc-encoding").unwrap(), expected);  in client_enabled_server_enabled()
40             req  in client_enabled_server_enabled()
50                         .map_request(move |req| {  in client_enabled_server_enabled()
51                             AssertRightEncoding::new(encoding).clone().call(req)  in client_enabled_server_enabled()
70     let req = Request::new(Box::pin(stream));  in client_enabled_server_enabled()  localVariable
72     client.compress_input_client_stream(req).await.unwrap();  in client_enabled_server_enabled()
93     fn assert_right_encoding<B>(req: http::Request<B>) -> http::Request<B> {  in client_disabled_server_enabled()
94         assert!(req.headers().get("grpc-encoding").is_none());  in client_disabled_server_enabled()
95         req  in client_disabled_server_enabled()
121     let req = Request::new(Box::pin(stream));  in client_disabled_server_enabled()  localVariable
123     client.compress_input_client_stream(req).await.unwrap();  in client_disabled_server_enabled()
155     let req = Request::new(Box::pin(stream));  in client_enabled_server_disabled()  localVariable
157     let status = client.compress_input_client_stream(req).await.unwrap_err();  in client_enabled_server_disabled()
214     let req = Request::new(Box::pin(tokio_stream::empty()));  in compressing_response_from_client_stream()  localVariable
216     let res = client.compress_output_client_stream(req).await.unwrap();  in compressing_response_from_client_stream()