16     let svc = test_server::TestServer::new(Svc::default()).accept_compressed(encoding);  in client_enabled_server_enabled()
18     let request_bytes_counter = Arc::new(AtomicUsize::new(0));  in client_enabled_server_enabled()
27         pub fn new(encoding: CompressionEncoding) -> Self {  in client_enabled_server_enabled()  method
49                     ServiceBuilder::new()  in client_enabled_server_enabled()
51                             AssertRightEncoding::new(encoding).clone().call(req)  in client_enabled_server_enabled()
66         test_client::TestClient::new(mock_io_channel(client).await).send_compressed(encoding);  in client_enabled_server_enabled()
70     let req = Request::new(Box::pin(stream));  in client_enabled_server_enabled()
89     let svc = test_server::TestServer::new(Svc::default()).accept_compressed(encoding);  in client_disabled_server_enabled()
91     let request_bytes_counter = Arc::new(AtomicUsize::new(0));  in client_disabled_server_enabled()
103                     ServiceBuilder::new()  in client_disabled_server_enabled()
117     let mut client = test_client::TestClient::new(mock_io_channel(client).await);  in client_disabled_server_enabled()
121     let req = Request::new(Box::pin(stream));  in client_disabled_server_enabled()
140     let svc = test_server::TestServer::new(Svc::default());  in client_enabled_server_disabled()
151         test_client::TestClient::new(mock_io_channel(client).await).send_compressed(encoding);  in client_enabled_server_disabled()
155     let req = Request::new(Box::pin(stream));  in client_enabled_server_disabled()
186     let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding);  in compressing_response_from_client_stream()
188     let response_bytes_counter = Arc::new(AtomicUsize::new(0));  in compressing_response_from_client_stream()
195                     ServiceBuilder::new()  in compressing_response_from_client_stream()
196                         .layer(MapResponseBodyLayer::new(move |body| {  in compressing_response_from_client_stream()
212         test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding);  in compressing_response_from_client_stream()
214     let req = Request::new(Box::pin(tokio_stream::empty()));  in compressing_response_from_client_stream()