Searched refs:conn (Results 1 – 10 of 10) sorted by relevance
| /tonic/examples/src/tls_rustls/ |
| H A D | server.rs | 5 use hyper::server::conn::http2::Builder;
53 let (conn, addr) = match listener.accept().await { in main()
68 let conn = tls_acceptor in main() localVariable
69 .accept_with(conn, |info| { in main()
84 TokioIo::new(conn), in main()
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | connection.rs | 8 use hyper::{client::conn::http2::Builder, rt::Executor};
73 let conn = Reconnect::new(make_service, endpoint.uri.clone(), is_lazy); in new() localVariable
76 inner: BoxService::new(stack.layer(conn)), in new()
133 inner: hyper::client::conn::http2::SendRequest<Body>,
136 impl From<hyper::client::conn::http2::SendRequest<Body>> for SendRequest {
137 fn from(inner: hyper::client::conn::http2::SendRequest<Body>) -> Self { in from()
196 let (send_request, conn) = builder.handshake(io).await?; in call()
201 if let Err(e) = conn.await { in call()
|
| /tonic/examples/src/h2c/ |
| H A D | client.rs | 80 let (mut h2_client, conn) = in call()
81 hyper::client::conn::http2::Builder::new(TokioExecutor::new()) in call()
85 tokio::spawn(conn); in call()
|
| H A D | server.rs | 4 use hyper_util::server::conn::auto::Builder;
52 let conn = builder.serve_connection_with_upgrades( in main() localVariable
56 let _ = conn.await; in main()
110 hyper::server::conn::http2::Builder::new(TokioExecutor::new()) in call()
|
| /tonic/tonic-reflection/tests/ |
| H A D | versions.rs | 85 let conn = tonic::transport::Endpoint::new(local_addr) in make_v1_request() localVariable
90 let mut client = v1::server_reflection_client::ServerReflectionClient::new(conn); in make_v1_request()
142 let conn = tonic::transport::Endpoint::new(local_addr) in make_v1alpha_request() localVariable
147 let mut client = v1alpha::server_reflection_client::ServerReflectionClient::new(conn); in make_v1alpha_request()
|
| H A D | server.rs | 121 let conn = tonic::transport::Endpoint::new(local_addr) in make_test_reflection_request() localVariable
126 let mut client = ServerReflectionClient::new(conn); in make_test_reflection_request()
|
| /tonic/tonic-health/ |
| H A D | README.md | 12 let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
13 let client = HealthClient::new(conn);
|
| /tonic/tonic/benches-disabled/benchmarks/compiled_protos/ |
| H A D | helloworld.rs | 28 let conn = tonic::transport::Endpoint::new(dst)?.connect().await?; in connect() localVariable
29 Ok(Self::new(conn)) in connect()
|
| /tonic/tonic/src/transport/server/ |
| H A D | mod.rs | 3 mod conn; module
21 pub use conn::{Connected, TcpConnectInfo};
24 server::conn::auto::{Builder as ConnectionBuilder, HttpServerConnExec},
31 pub use conn::TlsConnectInfo;
789 let mut conn = pin!(builder.serve_connection(hyper_io, hyper_svc)); in serve_connection() localVariable
796 rv = &mut conn => { in serve_connection()
803 conn.as_mut().graceful_shutdown(); in serve_connection()
807 conn.as_mut().graceful_shutdown(); in serve_connection()
|
| /tonic/tonic-build/src/ |
| H A D | client.rs | 149 let conn = tonic::transport::Endpoint::new(dst)?.connect().await?; in generate_connect() localVariable
150 Ok(Self::new(conn)) in generate_connect()
|