| /tonic/tests/integration_tests/tests/ |
| H A D | http2_keep_alive.rs | 25 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in http2_keepalive_does_not_cause_panics() localVariable
31 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in http2_keepalive_does_not_cause_panics()
55 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in http2_keepalive_does_not_cause_panics_on_client_side() localVariable
61 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in http2_keepalive_does_not_cause_panics_on_client_side()
|
| H A D | status.rs | 39 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in status_with_details() localVariable
44 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in status_with_details()
97 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in status_with_metadata() localVariable
102 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in status_with_metadata()
168 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in status_from_server_stream() localVariable
173 .serve_with_incoming(incoming) in status_from_server_stream()
238 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in message_and_then_status_from_server_stream() localVariable
243 .serve_with_incoming(incoming) in message_and_then_status_from_server_stream()
|
| H A D | connection.rs | 45 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in connect_returns_err_via_call_after_connected() localVariable
50 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in connect_returns_err_via_call_after_connected()
88 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in connect_lazy_reconnects_after_first_failure() localVariable
94 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in connect_lazy_reconnects_after_first_failure()
|
| H A D | extensions.rs | 44 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in setting_extension_from_interceptor() localVariable
49 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in setting_extension_from_interceptor()
93 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in setting_extension_from_tower() localVariable
98 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in setting_extension_from_tower()
|
| H A D | user_agent.rs | 29 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in writes_user_agent_header() localVariable
34 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in writes_user_agent_header()
|
| H A D | interceptor.rs | 28 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in interceptor_retrieves_grpc_method() localVariable
34 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in interceptor_retrieves_grpc_method()
|
| H A D | client_layer.rs | 31 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in connect_supports_standard_tower_layers() localVariable
37 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in connect_supports_standard_tower_layers()
|
| H A D | origin.rs | 36 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in writes_origin_header() localVariable
42 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in writes_origin_header()
|
| H A D | routes_builder.rs | 62 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in multiple_service_using_routes_builder() localVariable
67 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in multiple_service_using_routes_builder()
|
| H A D | connect_info.rs | 33 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in getting_connect_info() localVariable
38 .serve_with_incoming_shutdown(incoming, async { drop(rx.await) }) in getting_connect_info()
|
| /tonic/tonic/src/transport/server/ |
| H A D | mod.rs | 4 mod incoming; module
39 pub use incoming::TcpIncoming;
556 let incoming = self.bind_incoming(addr)?; in serve() localVariable
586 incoming: I, in serve_with_incoming()
608 incoming: I, in serve_with_incoming_shutdown()
630 incoming: I, in serve_internal()
667 incoming, in serve_internal()
710 let mut incoming = pin!(incoming); in serve_internal() localVariable
718 io = incoming.next() => { in serve_internal()
923 incoming: I, in serve_with_incoming()
[all …]
|
| H A D | io_stream.rs | 40 pub(crate) fn new(incoming: S, #[cfg(feature = "_tls-any")] tls: Option<TlsAcceptor>) -> Self { in new()
42 inner: incoming, in new()
146 incoming: &mut (impl Stream<Item = Result<IO, IE>> + Unpin), in select()
153 match incoming.try_next().await { in select()
|
| /tonic/examples/src/tls_rustls/ |
| H A D | server.rs | 54 Ok(incoming) => incoming, in main()
|
| /tonic/examples/src/h2c/ |
| H A D | server.rs | 41 let incoming = TcpListener::bind(addr).await?; in main() localVariable
47 match incoming.accept().await { in main()
|
| /tonic/ |
| H A D | CHANGELOG.md | 12 * **server:** ignore more error kinds in incoming socket stream (#1885)
|