55     let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding);  in client_enabled_server_enabled()
57     let response_bytes_counter = Arc::new(AtomicUsize::new(0));  in client_enabled_server_enabled()
64                     ServiceBuilder::new()  in client_enabled_server_enabled()
69                         .layer(MapResponseBodyLayer::new(move |body| {  in client_enabled_server_enabled()
85         test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding);  in client_enabled_server_enabled()
113     let svc = test_server::TestServer::new(Svc::default());  in client_enabled_server_disabled()
115     let response_bytes_counter = Arc::new(AtomicUsize::new(0));  in client_enabled_server_disabled()
123                     ServiceBuilder::new()  in client_enabled_server_disabled()
124                         .layer(MapResponseBodyLayer::new(move |body| {  in client_enabled_server_disabled()
140         test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding);  in client_enabled_server_disabled()
154     let svc = test_server::TestServer::new(Svc::default());  in client_enabled_server_disabled_multi_encoding()
156     let response_bytes_counter = Arc::new(AtomicUsize::new(0));  in client_enabled_server_disabled_multi_encoding()
164                     ServiceBuilder::new()  in client_enabled_server_disabled_multi_encoding()
165                         .layer(MapResponseBodyLayer::new(move |body| {  in client_enabled_server_disabled_multi_encoding()
180     let mut client = test_client::TestClient::new(mock_io_channel(client).await)  in client_enabled_server_disabled_multi_encoding()
228     let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding);  in client_disabled()
230     let response_bytes_counter = Arc::new(AtomicUsize::new(0));  in client_disabled()
237                     ServiceBuilder::new()  in client_disabled()
239                         .layer(MapResponseBodyLayer::new(move |body| {  in client_disabled()
254     let mut client = test_client::TestClient::new(mock_io_channel(client).await);  in client_disabled()
275     let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding);  in server_replying_with_unsupported_encoding()
287                 ServiceBuilder::new()  in server_replying_with_unsupported_encoding()
298         test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding);  in server_replying_with_unsupported_encoding()
319     let svc = test_server::TestServer::new(Svc {  in disabling_compression_on_single_response()
324     let response_bytes_counter = Arc::new(AtomicUsize::new(0));  in disabling_compression_on_single_response()
331                     ServiceBuilder::new()  in disabling_compression_on_single_response()
332                         .layer(MapResponseBodyLayer::new(move |body| {  in disabling_compression_on_single_response()
348         test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding);  in disabling_compression_on_single_response()
377     let svc = test_server::TestServer::new(Svc {  in disabling_compression_on_response_but_keeping_compression_on_stream()
382     let response_bytes_counter = Arc::new(AtomicUsize::new(0));  in disabling_compression_on_response_but_keeping_compression_on_stream()
389                     ServiceBuilder::new()  in disabling_compression_on_response_but_keeping_compression_on_stream()
390                         .layer(MapResponseBodyLayer::new(move |body| {  in disabling_compression_on_response_but_keeping_compression_on_stream()
406         test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding);  in disabling_compression_on_response_but_keeping_compression_on_stream()
446     let svc = test_server::TestServer::new(Svc {  in disabling_compression_on_response_from_client_stream()
451     let response_bytes_counter = Arc::new(AtomicUsize::new(0));  in disabling_compression_on_response_from_client_stream()
458                     ServiceBuilder::new()  in disabling_compression_on_response_from_client_stream()
459                         .layer(MapResponseBodyLayer::new(move |body| {  in disabling_compression_on_response_from_client_stream()
475         test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding);  in disabling_compression_on_response_from_client_stream()
477     let req = Request::new(Box::pin(tokio_stream::empty()));  in disabling_compression_on_response_from_client_stream()