14     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in client_enabled_server_enabled()
65     let mut client =  in client_enabled_server_enabled()  localVariable
66         test_client::TestClient::new(mock_io_channel(client).await).send_compressed(encoding);  in client_enabled_server_enabled()
72     client.compress_input_client_stream(req).await.unwrap();  in client_enabled_server_enabled()
87     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in client_disabled_server_enabled()
117     let mut client = test_client::TestClient::new(mock_io_channel(client).await);  in client_disabled_server_enabled()  localVariable
123     client.compress_input_client_stream(req).await.unwrap();  in client_disabled_server_enabled()
138     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in client_enabled_server_disabled()
150     let mut client =  in client_enabled_server_disabled()  localVariable
151         test_client::TestClient::new(mock_io_channel(client).await).send_compressed(encoding);  in client_enabled_server_disabled()
157     let status = client.compress_input_client_stream(req).await.unwrap_err();  in client_enabled_server_disabled()
184     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in compressing_response_from_client_stream()
211     let mut client =  in compressing_response_from_client_stream()  localVariable
212         test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding);  in compressing_response_from_client_stream()
216     let res = client.compress_output_client_stream(req).await.unwrap();  in compressing_response_from_client_stream()