| /tonic/examples/src/blocking/ |
| H A D | client.rs | 22 pub fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error> in connect() method
28 let client = rt.block_on(GreeterClient::connect(dst))?; in connect()
42 let mut client = BlockingClient::connect("http://[::1]:50051")?; in main()
|
| /tonic/examples/src/interceptor/ |
| H A D | client.rs | 17 .connect() in main()
54 .connect() in using_named_interceptor()
68 .connect() in using_function_pointer_interceptro()
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | connector.rs | 56 let connect = self.inner.call(uri); in call() localVariable
60 let io = connect.await?; in call()
65 let io = tls.connect(TokioIo::new(io)).await?; in call()
|
| H A D | tls.rs | 104 pub(crate) async fn connect<I>(&self, io: I) -> Result<BoxedIo, crate::BoxError> in connect() method
109 .connect(self.domain.as_ref().to_owned(), io) in connect()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | timeout.rs | 10 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 D | connection.rs | 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()
|
| H A D | http2_keep_alive.rs | 38 let mut client = TestClient::connect(format!("http://{addr}")).await.unwrap(); in http2_keepalive_does_not_cause_panics()
71 .connect() in http2_keepalive_does_not_cause_panics_on_client_side()
|
| H A D | status.rs | 51 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()
180 let mut client = test_stream_client::TestStreamClient::connect(format!("http://{addr}")) in status_from_server_stream()
250 let mut client = test_stream_client::TestStreamClient::connect(format!("http://{addr}")) in message_and_then_status_from_server_stream()
|
| /tonic/examples/src/helloworld/ |
| H A D | client.rs | 10 let mut client = GreeterClient::connect("http://[::1]:50051").await?; in main()
|
| /tonic/examples/src/codec_buffers/ |
| H A D | client.rs | 19 let mut client = GreeterClient::connect("http://[::1]:50051").await?; in main()
|
| /tonic/examples/src/json-codec/ |
| H A D | client.rs | 17 let mut client = GreeterClient::connect("http://[::1]:50051").await?; in main()
|
| /tonic/tests/web/tests/ |
| H A D | grpc.rs | 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/tonic/src/transport/channel/ |
| H A D | endpoint.rs | 11 use hyper_util::client::legacy::connect::HttpConnector;
350 pub async fn connect(&self) -> Result<Channel, Error> { in connect() method
351 Channel::connect(self.http_connector(), self.clone()).await in connect()
381 Channel::connect(connector, self.clone()).await in connect_with_connector()
383 Channel::connect(connector, self.clone()).await in connect_with_connector()
|
| /tonic/tests/default_stubs/src/ |
| H A D | test_defaults.rs | 20 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/examples/src/cancellation/ |
| H A D | client.rs | 12 let mut client = GreeterClient::connect("http://[::1]:50051").await?; in main()
|
| /tonic/examples/src/compression/ |
| H A D | client.rs | 13 .connect() in main()
|
| /tonic/examples/src/authentication/ |
| H A D | client.rs | 10 let channel = Channel::from_static("http://[::1]:50051").connect().await?; in main()
|
| /tonic/examples/src/tracing/ |
| H A D | client.rs | 20 let mut client = GreeterClient::connect("http://[::1]:50051").await?; in say_hi()
|
| /tonic/examples/src/richer-error/ |
| H A D | client.rs | 12 let mut client = GreeterClient::connect("http://[::1]:50051").await?; in main()
|
| H A D | client_vec.rs | 12 let mut client = GreeterClient::connect("http://[::1]:50051").await?; in main()
|
| /tonic/examples/src/tls/ |
| H A D | client.rs | 20 .connect() in main()
|
| /tonic/examples/src/multiplex/ |
| H A D | client.rs | 16 .connect() in main()
|
| /tonic/examples/src/uds/ |
| H A D | client.rs | 26 Ok::<_, std::io::Error>(TokioIo::new(UnixStream::connect(path).await?)) in main()
|
| /tonic/examples/src/tls_client_auth/ |
| H A D | client.rs | 24 .connect() in main()
|
| /tonic/tonic-reflection/tests/ |
| H A D | versions.rs | 87 .connect() in make_v1_request()
144 .connect() in make_v1alpha_request()
|