Home
last modified time | relevance | path

Searched defs:client (Results 1 – 25 of 55) sorted by relevance

123

/tonic/examples/src/grpc-web/
H A Dclient.rs12 let client = hyper_util::client::legacy::Client::builder(TokioExecutor::new()).build_http(); in main() localVariable
18 let mut client = GreeterClient::with_origin(svc, "http://127.0.0.1:3000".try_into()?); in main() localVariable
/tonic/examples/src/mock/
H A Dmock.rs33 let mut client = Some(client); in main() localVariable
36 let client = client.take(); in main() localVariable
48 let mut client = GreeterClient::new(channel); in main() localVariable
/tonic/tests/integration_tests/tests/
H A Dmax_message_size.rs159 let mut client = Some(client); in response_stream_limit() localVariable
163 let client = client.take(); in response_stream_limit() localVariable
176 let client = test1_client::Test1Client::new(channel); in response_stream_limit() localVariable
178 let mut client = client.max_decoding_message_size(6877902 + 5); in response_stream_limit() localVariable
325 let mut client = Some(client); in max_message_run() localVariable
329 let client = client.take(); in max_message_run() localVariable
342 let client = test1_client::Test1Client::new(channel); in max_message_run() localVariable
344 let client = if let Some(size) = case.client_recv_max { in max_message_run() localVariable
350 let mut client = if let Some(size) = case.client_send_max { in max_message_run() localVariable
H A Dconnection.rs57 let mut client = TestClient::connect(format!("http://{addr}")).await.unwrap(); in connect_returns_err_via_call_after_connected() localVariable
80 let mut client = TestClient::new(channel); in connect_lazy_reconnects_after_first_failure() localVariable
103 let mut client = TestClient::new(channel); in connect_lazy_reconnects_after_first_failure() localVariable
H A Dtimeout.rs10 let mut client = test_client::TestClient::connect(format!("http://{}", addr)) in cancelation_on_timeout() localVariable
30 let mut client = test_client::TestClient::connect(format!("http://{}", addr)) in picks_server_timeout_if_thats_sorter() localVariable
49 let mut client = test_client::TestClient::connect(format!("http://{}", addr)) in picks_client_timeout_if_thats_sorter() localVariable
H A Dhttp2_keep_alive.rs38 let mut client = TestClient::connect(format!("http://{addr}")).await.unwrap(); in http2_keepalive_does_not_cause_panics() localVariable
74 let mut client = TestClient::new(channel); in http2_keepalive_does_not_cause_panics_on_client_side() localVariable
/tonic/examples/src/interceptor/
H A Dclient.rs20 let mut client = GreeterClient::with_interceptor(channel, intercept); in main() localVariable
57 let client: GreeterClient<InterceptedService<Channel, MyInterceptor>> = in using_named_interceptor() localVariable
71 let client: GreeterClient< in using_function_pointer_interceptro() localVariable
/tonic/tests/compression/src/
H A Dserver_stream.rs41 let mut client = in client_enabled_server_enabled() localVariable
106 let mut client = test_client::TestClient::new(mock_io_channel(client).await); in client_disabled_server_enabled() localVariable
158 let mut client = in client_enabled_server_disabled() localVariable
H A Dcompressing_request.rs67 let mut client = in client_enabled_server_enabled() localVariable
129 let mut client = in client_enabled_server_enabled_multi_encoding() localVariable
165 let mut client = in client_enabled_server_disabled() localVariable
218 let mut client = test_client::TestClient::with_interceptor( in client_mark_compressed_without_header_server_enabled() localVariable
H A Dcompressing_response.rs84 let mut client = in client_enabled_server_enabled() localVariable
139 let mut client = in client_enabled_server_disabled() localVariable
180 let mut client = test_client::TestClient::new(mock_io_channel(client).await) in client_enabled_server_disabled_multi_encoding() localVariable
254 let mut client = test_client::TestClient::new(mock_io_channel(client).await); in client_disabled() localVariable
297 let mut client = in server_replying_with_unsupported_encoding() localVariable
347 let mut client = in disabling_compression_on_single_response() localVariable
405 let mut client = in disabling_compression_on_response_but_keeping_compression_on_stream() localVariable
474 let mut client = in disabling_compression_on_response_from_client_stream() localVariable
H A Dclient_stream.rs65 let mut client = in client_enabled_server_enabled() localVariable
117 let mut client = test_client::TestClient::new(mock_io_channel(client).await); in client_disabled_server_enabled() localVariable
150 let mut client = in client_enabled_server_disabled() localVariable
211 let mut client = in compressing_response_from_client_stream() localVariable
/tonic/examples/src/blocking/
H A Dclient.rs17 client: GreeterClient<tonic::transport::Channel>, field
28 let client = rt.block_on(GreeterClient::connect(dst))?; in connect() localVariable
42 let mut client = BlockingClient::connect("http://[::1]:50051")?; in main() localVariable
/tonic/examples/src/h2c/
H A Dclient.rs18 let mut client = GreeterClient::with_origin(h2c_client, origin); in main() localVariable
46 pub client: Client<HttpConnector, Body>, field
60 let client = self.client.clone(); in call() localVariable
/tonic/examples/src/tls_rustls/
H A Dclient.rs53 let client = hyper_util::client::legacy::Client::builder(TokioExecutor::new()).build(connector); in main() localVariable
58 let mut client = EchoClient::with_origin(client, uri); in main() localVariable
/tonic/examples/src/helloworld/
H A Dclient.rs10 let mut client = GreeterClient::connect("http://[::1]:50051").await?; in main() localVariable
/tonic/examples/src/cancellation/
H A Dclient.rs12 let mut client = GreeterClient::connect("http://[::1]:50051").await?; in main() localVariable
/tonic/examples/src/codec_buffers/
H A Dclient.rs19 let mut client = GreeterClient::connect("http://[::1]:50051").await?; in main() localVariable
/tonic/examples/src/compression/
H A Dclient.rs17 let mut client = GreeterClient::new(channel) in main() localVariable
/tonic/examples/src/richer-error/
H A Dclient.rs12 let mut client = GreeterClient::connect("http://[::1]:50051").await?; in main() localVariable
H A Dclient_vec.rs12 let mut client = GreeterClient::connect("http://[::1]:50051").await?; in main() localVariable
/tonic/examples/src/json-codec/
H A Dclient.rs17 let mut client = GreeterClient::connect("http://[::1]:50051").await?; in main() localVariable
/tonic/examples/src/authentication/
H A Dclient.rs14 let mut client = EchoClient::with_interceptor(channel, move |mut req: Request<()>| { in main() localVariable
/tonic/examples/src/load_balance/
H A Dclient.rs16 let mut client = EchoClient::new(channel); in main() localVariable
/tonic/tonic-web/src/
H A Dlib.rs79 mod client; module
/tonic/examples/src/tracing/
H A Dclient.rs20 let mut client = GreeterClient::connect("http://[::1]:50051").await?; in say_hi() localVariable

123