Home
last modified time | relevance | path

Searched refs:TestClient (Results 1 – 21 of 21) sorted by relevance

/tonic/tests/integration_tests/tests/
H A Dconnection.rs1 use integration_tests::pb::{test_client::TestClient, test_server, Input, Output};
24 let res = TestClient::connect("http://thisdoesntexist.test").await; in connect_returns_err()
34 TestClient::connect("https://github.com").await.unwrap(); in connect_handles_tls()
57 let mut client = TestClient::connect(format!("http://{addr}")).await.unwrap(); in connect_returns_err_via_call_after_connected()
80 let mut client = TestClient::new(channel); in connect_lazy_reconnects_after_first_failure()
103 let mut client = TestClient::new(channel); in connect_lazy_reconnects_after_first_failure()
H A Dhttp2_keep_alive.rs5 use integration_tests::pb::{test_client::TestClient, test_server, Input, Output};
38 let mut client = TestClient::connect(format!("http://{addr}")).await.unwrap(); in http2_keepalive_does_not_cause_panics()
74 let mut client = TestClient::new(channel); in http2_keepalive_does_not_cause_panics_on_client_side()
H A Dtimeout.rs10 let mut client = test_client::TestClient::connect(format!("http://{}", addr)) in cancelation_on_timeout()
30 let mut client = test_client::TestClient::connect(format!("http://{}", addr)) in picks_server_timeout_if_thats_sorter()
49 let mut client = test_client::TestClient::connect(format!("http://{}", addr)) in picks_client_timeout_if_thats_sorter()
H A Dinterceptor.rs1 use integration_tests::pb::{test_client::TestClient, test_server, Input, Output};
52 let mut client = TestClient::with_interceptor(channel, client_intercept); in interceptor_retrieves_grpc_method()
H A Dclient_layer.rs2 use integration_tests::pb::{test_client::TestClient, test_server, Input, Output};
48 let mut client = TestClient::new( in connect_supports_standard_tower_layers()
H A Dconnect_info.rs51 let mut client = test_client::TestClient::new(channel); in getting_connect_info()
127 let mut client = test_client::TestClient::new(channel); in getting_connect_info()
H A Dextensions.rs62 let mut client = test_client::TestClient::new(channel); in setting_extension_from_interceptor()
111 let mut client = test_client::TestClient::new(channel); in setting_extension_from_tower()
H A Duser_agent.rs49 let mut client = test_client::TestClient::new(channel); in writes_user_agent_header()
H A Dhttp2_max_header_list_size.rs61 let mut client = test_client::TestClient::new(channel); in test_http_max_header_list_size_and_long_errors()
H A Dstatus.rs51 let mut channel = test_client::TestClient::connect(format!("http://{addr}")) in status_with_details()
109 let mut channel = test_client::TestClient::connect(format!("http://{addr}")) in status_with_metadata()
H A Dorigin.rs56 let mut client = test_client::TestClient::new(channel); in writes_origin_header()
H A Droutes_builder.rs80 let mut client1 = test_client::TestClient::new(channel.clone()); in multiple_service_using_routes_builder()
/tonic/interop/src/
H A Dclient.rs10 pub type TestClient = TestServiceClient<Channel>; typedef
21 pub async fn empty_unary(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in empty_unary() argument
40 pub async fn large_unary(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in large_unary() argument
84 pub async fn client_streaming(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in client_streaming() argument
111 pub async fn server_streaming(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in server_streaming() argument
153 pub async fn ping_pong(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in ping_pong() argument
209 pub async fn empty_stream(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in empty_stream() argument
230 pub async fn status_code_and_message(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in status_code_and_message() argument
286 pub async fn special_status_message(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in special_status_message() argument
316 pub async fn unimplemented_method(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in unimplemented_method() argument
[all …]
/tonic/tests/web/tests/
H A Dgrpc.rs12 use test_web::pb::{test_client::TestClient, test_server::TestServer, Input};
126 type Client = TestClient<Channel>;
137 TestClient::connect(u1), in spawn()
138 TestClient::connect(u2), in spawn()
139 TestClient::connect(u3), in spawn()
140 TestClient::connect(u4) in spawn()
/tonic/tests/compression/src/
H A Dcompressing_response.rs85 test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding); in client_enabled_server_enabled()
140 test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding); in client_enabled_server_disabled()
180 let mut client = test_client::TestClient::new(mock_io_channel(client).await) in client_enabled_server_disabled_multi_encoding()
254 let mut client = test_client::TestClient::new(mock_io_channel(client).await); in client_disabled()
298 test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding); in server_replying_with_unsupported_encoding()
348 test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding); in disabling_compression_on_single_response()
406 test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding); in disabling_compression_on_response_but_keeping_compression_on_stream()
475 test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding); in disabling_compression_on_response_from_client_stream()
H A Dcompressing_request.rs68 test_client::TestClient::new(mock_io_channel(client).await).send_compressed(encoding); in client_enabled_server_enabled()
130 test_client::TestClient::new(mock_io_channel(client).await).send_compressed(encoding); in client_enabled_server_enabled_multi_encoding()
166 test_client::TestClient::new(mock_io_channel(client).await).send_compressed(encoding); in client_enabled_server_disabled()
218 let mut client = test_client::TestClient::with_interceptor( in client_mark_compressed_without_header_server_enabled()
H A Dserver_stream.rs42 test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding); in client_enabled_server_enabled()
106 let mut client = test_client::TestClient::new(mock_io_channel(client).await); in client_disabled_server_enabled()
159 test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding); in client_enabled_server_disabled()
H A Dclient_stream.rs66 test_client::TestClient::new(mock_io_channel(client).await).send_compressed(encoding); in client_enabled_server_enabled()
117 let mut client = test_client::TestClient::new(mock_io_channel(client).await); in client_disabled_server_enabled()
151 test_client::TestClient::new(mock_io_channel(client).await).send_compressed(encoding); in client_enabled_server_disabled()
212 test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding); in compressing_response_from_client_stream()
H A Dbidirectional_stream.rs75 let mut client = test_client::TestClient::new(mock_io_channel(client).await) in client_enabled_server_enabled()
/tonic/tests/default_stubs/src/
H A Dtest_defaults.rs20 let mut client = test_client::TestClient::connect(format!("http://{}", addrs.0)) in test_default_stubs()
49 let mut client_default_stubs = test_client::TestClient::connect(format!("http://{}", addrs.1)) in test_default_stubs()
/tonic/interop/src/bin/
H A Dclient.rs51 let mut client = client::TestClient::new(channel.clone()); in main()