Lines Matching refs:new
16 let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding); in client_enabled_server_enabled()
18 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled()
25 ServiceBuilder::new() in client_enabled_server_enabled()
26 .layer(MapResponseBodyLayer::new(move |body| { in client_enabled_server_enabled()
42 test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding); in client_enabled_server_enabled()
81 let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding); in client_disabled_server_enabled()
83 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_disabled_server_enabled()
90 ServiceBuilder::new() in client_disabled_server_enabled()
91 .layer(MapResponseBodyLayer::new(move |body| { in client_disabled_server_enabled()
106 let mut client = test_client::TestClient::new(mock_io_channel(client).await); in client_disabled_server_enabled()
133 let svc = test_server::TestServer::new(Svc::default()); in client_enabled_server_disabled()
135 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_disabled()
142 ServiceBuilder::new() in client_enabled_server_disabled()
143 .layer(MapResponseBodyLayer::new(move |body| { in client_enabled_server_disabled()
159 test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding); in client_enabled_server_disabled()