| /tonic/examples/src/dynamic_load_balance/ |
| H A D | client.rs | 20 let (channel, rx) = Channel::balance_channel(10); in main()
29 let res = rx.send(change).await; in main()
34 let res = rx.send(change).await; in main()
39 let res = rx.send(change).await; in main()
45 let res = rx.send(change).await; in main()
52 let res = rx.send(change).await; in main()
58 let res = rx.send(change).await; in main()
69 let rx = client.unary_echo(request); in main() localVariable
70 if let Ok(resp) = timeout(tokio::time::Duration::from_secs(10), rx).await { in main()
|
| H A D | server.rs | 31 let (tx, mut rx) = mpsc::unbounded_channel(); in main()
51 rx.recv().await; in main()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | http2_keep_alive.rs | 21 let (tx, rx) = oneshot::channel::<()>(); in http2_keepalive_does_not_cause_panics()
31 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in http2_keepalive_does_not_cause_panics()
51 let (tx, rx) = oneshot::channel::<()>(); in http2_keepalive_does_not_cause_panics_on_client_side()
61 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in http2_keepalive_does_not_cause_panics_on_client_side()
|
| H A D | connection.rs | 39 let (tx, rx) = oneshot::channel(); in connect_returns_err_via_call_after_connected()
50 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in connect_returns_err_via_call_after_connected()
74 let (tx, rx) = oneshot::channel(); in connect_lazy_reconnects_after_first_failure()
94 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in connect_lazy_reconnects_after_first_failure()
|
| H A D | connect_info.rs | 29 let (tx, rx) = oneshot::channel::<()>(); in getting_connect_info()
38 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in getting_connect_info()
105 let (tx, rx) = oneshot::channel::<()>(); in getting_connect_info()
110 .serve_with_incoming_shutdown(uds_stream, async { drop(rx.await) }) in getting_connect_info()
|
| H A D | extensions.rs | 40 let (tx, rx) = oneshot::channel::<()>(); in setting_extension_from_interceptor()
49 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in setting_extension_from_interceptor()
89 let (tx, rx) = oneshot::channel::<()>(); in setting_extension_from_tower()
98 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in setting_extension_from_tower()
|
| H A D | streams.rs | 29 let (tx, rx) = oneshot::channel::<()>(); in status_from_server_stream_with_source()
34 .serve_with_shutdown("127.0.0.1:0".parse().unwrap(), async { drop(rx.await) }) in status_from_server_stream_with_source()
|
| H A D | user_agent.rs | 25 let (tx, rx) = oneshot::channel::<()>(); in writes_user_agent_header()
34 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in writes_user_agent_header()
|
| H A D | interceptor.rs | 24 let (tx, rx) = oneshot::channel(); in interceptor_retrieves_grpc_method()
34 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in interceptor_retrieves_grpc_method()
|
| H A D | http2_max_header_list_size.rs | 32 let (tx, rx) = oneshot::channel::<()>(); in test_http_max_header_list_size_and_long_errors()
44 .serve_with_incoming_shutdown(listener, async { drop(rx.await) }) in test_http_max_header_list_size_and_long_errors()
|
| H A D | client_layer.rs | 26 let (tx, rx) = oneshot::channel(); in connect_supports_standard_tower_layers()
37 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in connect_supports_standard_tower_layers()
|
| H A D | status.rs | 35 let (tx, rx) = oneshot::channel::<()>(); in status_with_details()
44 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in status_with_details()
93 let (tx, rx) = oneshot::channel::<()>(); in status_with_metadata()
102 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in status_with_metadata()
|
| H A D | origin.rs | 32 let (tx, rx) = oneshot::channel::<()>(); in writes_origin_header()
42 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in writes_origin_header()
|
| H A D | routes_builder.rs | 56 let (tx, rx) = oneshot::channel::<()>(); in multiple_service_using_routes_builder()
67 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in multiple_service_using_routes_builder()
|
| /tonic/examples/src/streaming/ |
| H A D | server.rs | 61 let (tx, rx) = mpsc::channel(128); in server_streaming_echo()
77 let output_stream = ReceiverStream::new(rx); in server_streaming_echo()
99 let (tx, rx) = mpsc::channel(128); in bidirectional_streaming_echo()
133 let out_stream = ReceiverStream::new(rx); in bidirectional_streaming_echo()
|
| /tonic/examples/src/load_balance/ |
| H A D | server.rs | 31 let (tx, mut rx) = mpsc::unbounded_channel(); in main()
51 rx.recv().await; in main()
|
| /tonic/tests/compression/src/ |
| H A D | util.rs | 88 rx: tokio::sync::mpsc::Receiver<Frame<T>>, field
93 let (tx, rx) = tokio::sync::mpsc::channel(32); in new()
94 (tx, Self { rx }) in new()
109 let frame = ready!(self.project().rx.poll_recv(cx)); in poll_frame()
|
| /tonic/examples/src/routeguide/ |
| H A D | server.rs | 47 let (tx, rx) = mpsc::channel(4); in list_features()
61 Ok(Response::new(ReceiverStream::new(rx))) in list_features()
|
| /tonic/tonic/src/transport/channel/ |
| H A D | mod.rs | 142 let (tx, rx) = channel(capacity); in balance_channel_with_executor()
143 let list = DynamicServiceStream::new(rx); in balance_channel_with_executor()
|
| /tonic/tonic-health/src/ |
| H A D | server.rs | 139 Some((_tx, rx)) => rx.clone(), in watch()
|
| /tonic/interop/src/ |
| H A D | client.rs | 154 let (tx, rx) = mpsc::unbounded_channel(); in ping_pong()
159 tokio_stream::wrappers::UnboundedReceiverStream::new(rx), in ping_pong()
|
| /tonic/ |
| H A D | CONTRIBUTING.md | 164 /// let (tx, rx) = mpsc::unbounded();
168 /// let process = rx.for_each(|item| {
199 /// let (tx, rx) = oneshot::channel();
204 /// Timeout::new(rx, Duration::from_millis(10))
|
| /tonic/examples/ |
| H A D | routeguide-tutorial.md | 404 let (tx, rx) = mpsc::channel(4);
415 Ok(Response::new(ReceiverStream::new(rx)))
|