Lines Matching refs:client

14     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in client_enabled_server_enabled()
67 let mut client = in client_enabled_server_enabled() localVariable
68 test_client::TestClient::new(mock_io_channel(client).await).send_compressed(encoding); in client_enabled_server_enabled()
71 client in client_enabled_server_enabled()
91 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled_multi_encoding()
129 let mut client = in client_enabled_server_enabled_multi_encoding() localVariable
130 test_client::TestClient::new(mock_io_channel(client).await).send_compressed(encoding); in client_enabled_server_enabled_multi_encoding()
133 client in client_enabled_server_enabled_multi_encoding()
153 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled()
165 let mut client = in client_enabled_server_disabled() localVariable
166 test_client::TestClient::new(mock_io_channel(client).await).send_compressed(encoding); in client_enabled_server_disabled()
168 let status = client in client_enabled_server_disabled()
204 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_mark_compressed_without_header_server_enabled()
218 let mut client = test_client::TestClient::with_interceptor( in client_mark_compressed_without_header_server_enabled() localVariable
219 mock_io_channel(client).await, in client_mark_compressed_without_header_server_enabled()
227 let status = client in client_mark_compressed_without_header_server_enabled()