Lines Matching refs:new

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 ServiceBuilder::new() in client_enabled_server_enabled()
53 AssertRightEncoding::new(encoding).clone().call(req) in client_enabled_server_enabled()
68 test_client::TestClient::new(mock_io_channel(client).await).send_compressed(encoding); in client_enabled_server_enabled()
93 let svc = test_server::TestServer::new(Svc::default()) in client_enabled_server_enabled_multi_encoding()
98 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled_multi_encoding()
113 ServiceBuilder::new() in client_enabled_server_enabled_multi_encoding()
115 ServiceBuilder::new() in client_enabled_server_enabled_multi_encoding()
130 test_client::TestClient::new(mock_io_channel(client).await).send_compressed(encoding); in client_enabled_server_enabled_multi_encoding()
155 let svc = test_server::TestServer::new(Svc::default()); in client_enabled_server_disabled()
166 test_client::TestClient::new(mock_io_channel(client).await).send_compressed(encoding); in client_enabled_server_disabled()
206 let svc = test_server::TestServer::new(Svc::default()).accept_compressed(encoding); in client_mark_compressed_without_header_server_enabled()