13     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in client_enabled_server_enabled()
84     let mut client =  in client_enabled_server_enabled()  localVariable
85         test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding);  in client_enabled_server_enabled()
95         let res = client.compress_output_unary(()).await.unwrap();  in client_enabled_server_enabled()
111     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in client_enabled_server_disabled()
139     let mut client =  in client_enabled_server_disabled()  localVariable
140         test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding);  in client_enabled_server_disabled()
142     let res = client.compress_output_unary(()).await.unwrap();  in client_enabled_server_disabled()
152     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  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()  localVariable
185     let res = client.compress_output_unary(()).await.unwrap();  in client_enabled_server_disabled_multi_encoding()
202     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in client_disabled()
254     let mut client = test_client::TestClient::new(mock_io_channel(client).await);  in client_disabled()  localVariable
256     let res = client.compress_output_unary(()).await.unwrap();  in client_disabled()
273     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in server_replying_with_unsupported_encoding()
297     let mut client =  in server_replying_with_unsupported_encoding()  localVariable
298         test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding);  in server_replying_with_unsupported_encoding()
299     let status: Status = client.compress_output_unary(()).await.unwrap_err();  in server_replying_with_unsupported_encoding()
317     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in disabling_compression_on_single_response()
347     let mut client =  in disabling_compression_on_single_response()  localVariable
348         test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding);  in disabling_compression_on_single_response()
350     let res = client.compress_output_unary(()).await.unwrap();  in disabling_compression_on_single_response()
375     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in disabling_compression_on_response_but_keeping_compression_on_stream()
405     let mut client =  in disabling_compression_on_response_but_keeping_compression_on_stream()  localVariable
406         test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding);  in disabling_compression_on_response_but_keeping_compression_on_stream()
408     let res = client.compress_output_server_stream(()).await.unwrap();  in disabling_compression_on_response_but_keeping_compression_on_stream()
444     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in disabling_compression_on_response_from_client_stream()
474     let mut client =  in disabling_compression_on_response_from_client_stream()  localVariable
475         test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding);  in disabling_compression_on_response_from_client_stream()
479     let res = client.compress_output_client_stream(req).await.unwrap();  in disabling_compression_on_response_from_client_stream()