Home
last modified time | relevance | path

Searched refs:channel (Results 1 – 25 of 48) sorted by relevance

12

/tonic/examples/src/interceptor/
H A Dclient.rs16 let channel = Endpoint::from_static("http://[::1]:50051") in main() localVariable
20 let mut client = GreeterClient::with_interceptor(channel, intercept); in main()
53 let channel = Endpoint::from_static("http://[::1]:50051") in using_named_interceptor() localVariable
58 GreeterClient::with_interceptor(channel, MyInterceptor); in using_named_interceptor()
67 let channel = Endpoint::from_static("http://[::1]:50051") in using_function_pointer_interceptro() localVariable
73 > = GreeterClient::with_interceptor(channel, intercept); in using_function_pointer_interceptro()
/tonic/tonic/src/transport/
H A Dmod.rs92 pub mod channel; module
103 pub use self::channel::{Channel, Endpoint};
116 pub use self::channel::ClientTlsConfig;
/tonic/examples/src/multiplex/
H A Dclient.rs15 let channel = Endpoint::from_static("http://[::1]:50051") in main() localVariable
19 let mut greeter_client = GreeterClient::new(channel.clone()); in main()
20 let mut echo_client = EchoClient::new(channel); in main()
/tonic/tests/integration_tests/tests/
H A Dconnection.rs39 let (tx, rx) = oneshot::channel(); in connect_returns_err_via_call_after_connected()
74 let (tx, rx) = oneshot::channel(); in connect_lazy_reconnects_after_first_failure()
79 let channel = Endpoint::from_static("http://127.0.0.1:0").connect_lazy(); in connect_lazy_reconnects_after_first_failure() localVariable
80 let mut client = TestClient::new(channel); in connect_lazy_reconnects_after_first_failure()
99 let channel = Endpoint::from_shared(format!("http://{addr}")) in connect_lazy_reconnects_after_first_failure() localVariable
103 let mut client = TestClient::new(channel); in connect_lazy_reconnects_after_first_failure()
H A Dconnect_info.rs29 let (tx, rx) = oneshot::channel::<()>(); in getting_connect_info()
45 let channel = Endpoint::from_shared(format!("http://{addr}")) in getting_connect_info() localVariable
51 let mut client = test_client::TestClient::new(channel); in getting_connect_info()
105 let (tx, rx) = oneshot::channel::<()>(); in getting_connect_info()
118 let channel = Endpoint::try_from("http://[::]:50051") in getting_connect_info() localVariable
127 let mut client = test_client::TestClient::new(channel); in getting_connect_info()
H A Dextensions.rs40 let (tx, rx) = oneshot::channel::<()>(); in setting_extension_from_interceptor()
56 let channel = Endpoint::from_shared(format!("http://{addr}")) in setting_extension_from_interceptor() localVariable
62 let mut client = test_client::TestClient::new(channel); in setting_extension_from_interceptor()
89 let (tx, rx) = oneshot::channel::<()>(); in setting_extension_from_tower()
105 let channel = Endpoint::from_shared(format!("http://{addr}")) in setting_extension_from_tower() localVariable
111 let mut client = test_client::TestClient::new(channel); in setting_extension_from_tower()
H A Dhttp2_keep_alive.rs21 let (tx, rx) = oneshot::channel::<()>(); in http2_keepalive_does_not_cause_panics()
51 let (tx, rx) = oneshot::channel::<()>(); in http2_keepalive_does_not_cause_panics_on_client_side()
68 let channel = Channel::from_shared(format!("http://{addr}")) in http2_keepalive_does_not_cause_panics_on_client_side() localVariable
74 let mut client = TestClient::new(channel); in http2_keepalive_does_not_cause_panics_on_client_side()
H A Duser_agent.rs25 let (tx, rx) = oneshot::channel::<()>(); in writes_user_agent_header()
41 let channel = Endpoint::from_shared(format!("http://{addr}")) in writes_user_agent_header() localVariable
49 let mut client = test_client::TestClient::new(channel); in writes_user_agent_header()
H A Dinterceptor.rs24 let (tx, rx) = oneshot::channel(); in interceptor_retrieves_grpc_method()
39 let channel = Endpoint::from_shared(format!("http://{addr}")) in interceptor_retrieves_grpc_method() localVariable
52 let mut client = TestClient::with_interceptor(channel, client_intercept); in interceptor_retrieves_grpc_method()
H A Dstatus.rs35 let (tx, rx) = oneshot::channel::<()>(); in status_with_details()
51 let mut channel = test_client::TestClient::connect(format!("http://{addr}")) in status_with_details() localVariable
55 let err = channel in status_with_details()
93 let (tx, rx) = oneshot::channel::<()>(); in status_with_metadata()
109 let mut channel = test_client::TestClient::connect(format!("http://{addr}")) in status_with_metadata() localVariable
113 let err = channel in status_with_metadata()
198 let channel = Endpoint::try_from("http://[::]:50051") in status_from_server_stream_with_source() localVariable
204 let mut client = test_stream_client::TestStreamClient::new(channel); in status_from_server_stream_with_source()
H A Dhttp2_max_header_list_size.rs32 let (tx, rx) = oneshot::channel::<()>(); in test_http_max_header_list_size_and_long_errors()
51 let channel = Endpoint::from_shared(addr) in test_http_max_header_list_size_and_long_errors() localVariable
61 let mut client = test_client::TestClient::new(channel); in test_http_max_header_list_size_and_long_errors()
H A Dclient_layer.rs26 let (tx, rx) = oneshot::channel(); in connect_supports_standard_tower_layers()
42 let channel = Endpoint::from_shared(format!("http://{addr}")) in connect_supports_standard_tower_layers() localVariable
55 .service(channel), in connect_supports_standard_tower_layers()
H A Droutes_builder.rs56 let (tx, rx) = oneshot::channel::<()>(); in multiple_service_using_routes_builder()
74 let channel = Endpoint::from_shared(format!("http://{addr}")) in multiple_service_using_routes_builder() localVariable
80 let mut client1 = test_client::TestClient::new(channel.clone()); in multiple_service_using_routes_builder()
81 let mut client2 = test1_client::Test1Client::new(channel); in multiple_service_using_routes_builder()
H A Dorigin.rs32 let (tx, rx) = oneshot::channel::<()>(); in writes_origin_header()
49 let channel = Endpoint::from_shared(format!("http://{addr}")) in writes_origin_header() localVariable
56 let mut client = test_client::TestClient::new(channel); in writes_origin_header()
/tonic/examples/src/tower/
H A Dclient.rs14 let channel = Channel::from_static("http://[::1]:50051").connect().await?; in main() localVariable
16 let channel = ServiceBuilder::new() in main() localVariable
20 .service(channel); in main()
22 let mut client = GreeterClient::new(channel); in main()
/tonic/examples/src/load_balance/
H A Dclient.rs14 let channel = Channel::balance_list(endpoints); in main() localVariable
16 let mut client = EchoClient::new(channel); in main()
/tonic/examples/src/compression/
H A Dclient.rs12 let channel = Channel::builder("http://[::1]:50051".parse().unwrap()) in main() localVariable
17 let mut client = GreeterClient::new(channel) in main()
/tonic/examples/src/authentication/
H A Dclient.rs10 let channel = Channel::from_static("http://[::1]:50051").connect().await?; in main() localVariable
14 let mut client = EchoClient::with_interceptor(channel, move |mut req: Request<()>| { in main()
/tonic/examples/src/tls/
H A Dclient.rs18 let channel = Channel::from_static("https://[::1]:50051") in main() localVariable
23 let mut client = EchoClient::new(channel); in main()
/tonic/examples/src/uds/
H A Dclient.rs21 let channel = Endpoint::try_from("http://[::]:50051")? in main() localVariable
30 let mut client = GreeterClient::new(channel); in main()
/tonic/examples/src/tls_client_auth/
H A Dclient.rs22 let channel = Channel::from_static("https://[::1]:50051") in main() localVariable
27 let mut client = EchoClient::new(channel); in main()
/tonic/examples/src/gcp/
H A Dclient.rs34 let channel = Channel::from_static(ENDPOINT) in main() localVariable
39 let mut service = PublisherClient::with_interceptor(channel, move |mut req: Request<()>| { in main()
/tonic/examples/src/dynamic_load_balance/
H A Dclient.rs6 use tonic::transport::channel::Change;
20 let (channel, rx) = Channel::balance_channel(10); in main()
21 let mut client = EchoClient::new(channel); in main()
/tonic/tonic/
H A DCargo.toml35 tls-native-roots = ["_tls-any", "channel", "dep:rustls-native-certs"]
36 tls-webpki-roots = ["_tls-any","channel", "dep:webpki-roots"]
47 channel = [
54 transport = ["server", "channel"]
98 # channel
/tonic/examples/src/mock/
H A Dmock.rs34 let channel = Endpoint::try_from("http://[::]:50051")? in main() localVariable
48 let mut client = GreeterClient::new(channel); in main()

12