Home
last modified time | relevance | path

Searched refs:listener (Results 1 – 20 of 20) sorted by relevance

/tonic/examples/src/autoreload/
H A Dserver.rs38 Some(listener) => { in main()
39 listener.set_nonblocking(true)?; in main()
40 let listener = tokio_stream::wrappers::TcpListenerStream::new( in main() localVariable
41 tokio::net::TcpListener::from_std(listener)?, in main()
44 server.serve_with_incoming(listener).await?; in main()
/tonic/tests/integration_tests/tests/
H A Dhttp2_max_header_list_size.rs33 let listener = tokio::net::TcpListener::bind("127.0.0.1:0").await.unwrap(); in test_http_max_header_list_size_and_long_errors() localVariable
34 let addr = format!("http://{}", listener.local_addr().unwrap()); in test_http_max_header_list_size_and_long_errors()
38 let listener = tonic::transport::server::TcpIncoming::from(listener) in test_http_max_header_list_size_and_long_errors() localVariable
44 .serve_with_incoming_shutdown(listener, async { drop(rx.await) }) in test_http_max_header_list_size_and_long_errors()
H A Dhttp2_keep_alive.rs23 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in http2_keepalive_does_not_cause_panics() localVariable
24 let addr = listener.local_addr().unwrap(); in http2_keepalive_does_not_cause_panics()
25 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in http2_keepalive_does_not_cause_panics()
53 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in http2_keepalive_does_not_cause_panics_on_client_side() localVariable
54 let addr = listener.local_addr().unwrap(); in http2_keepalive_does_not_cause_panics_on_client_side()
55 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in http2_keepalive_does_not_cause_panics_on_client_side()
H A Dstatus.rs37 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in status_with_details() localVariable
38 let addr = listener.local_addr().unwrap(); in status_with_details()
39 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in status_with_details()
95 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in status_with_metadata() localVariable
96 let addr = listener.local_addr().unwrap(); in status_with_metadata()
97 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in status_with_metadata()
166 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in status_from_server_stream() localVariable
167 let addr = listener.local_addr().unwrap(); in status_from_server_stream()
168 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in status_from_server_stream()
236 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in message_and_then_status_from_server_stream() localVariable
[all …]
H A Dconnection.rs43 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in connect_returns_err_via_call_after_connected() localVariable
44 let addr = listener.local_addr().unwrap(); in connect_returns_err_via_call_after_connected()
45 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in connect_returns_err_via_call_after_connected()
86 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in connect_lazy_reconnects_after_first_failure() localVariable
87 let addr = listener.local_addr().unwrap(); in connect_lazy_reconnects_after_first_failure()
88 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in connect_lazy_reconnects_after_first_failure()
H A Dextensions.rs42 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in setting_extension_from_interceptor() localVariable
43 let addr = listener.local_addr().unwrap(); in setting_extension_from_interceptor()
44 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in setting_extension_from_interceptor()
91 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in setting_extension_from_tower() localVariable
92 let addr = listener.local_addr().unwrap(); in setting_extension_from_tower()
93 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in setting_extension_from_tower()
H A Duser_agent.rs27 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in writes_user_agent_header() localVariable
28 let addr = listener.local_addr().unwrap(); in writes_user_agent_header()
29 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in writes_user_agent_header()
H A Dinterceptor.rs26 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in interceptor_retrieves_grpc_method() localVariable
27 let addr = listener.local_addr().unwrap(); in interceptor_retrieves_grpc_method()
28 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in interceptor_retrieves_grpc_method()
H A Dclient_layer.rs29 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in connect_supports_standard_tower_layers() localVariable
30 let addr = listener.local_addr().unwrap(); in connect_supports_standard_tower_layers()
31 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in connect_supports_standard_tower_layers()
H A Dtimeout.rs79 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in run_service_in_background() localVariable
80 let addr = listener.local_addr().unwrap(); in run_service_in_background()
86 .serve_with_incoming(tokio_stream::wrappers::TcpListenerStream::new(listener)) in run_service_in_background()
H A Dorigin.rs34 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in writes_origin_header() localVariable
35 let addr = listener.local_addr().unwrap(); in writes_origin_header()
36 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in writes_origin_header()
H A Droutes_builder.rs60 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in multiple_service_using_routes_builder() localVariable
61 let addr = listener.local_addr().unwrap(); in multiple_service_using_routes_builder()
62 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in multiple_service_using_routes_builder()
H A Dconnect_info.rs31 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in getting_connect_info() localVariable
32 let addr = listener.local_addr().unwrap(); in getting_connect_info()
33 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in getting_connect_info()
/tonic/tonic-reflection/tests/
H A Dversions.rs67 let listener = tokio::net::TcpListener::bind(addr).await.expect("bind"); in make_v1_request() localVariable
68 let local_addr = format!("http://{}", listener.local_addr().expect("local address")); in make_v1_request()
74 .serve_with_incoming_shutdown(TcpListenerStream::new(listener), async { in make_v1_request()
124 let listener = tokio::net::TcpListener::bind(addr).await.expect("bind"); in make_v1alpha_request() localVariable
125 let local_addr = format!("http://{}", listener.local_addr().expect("local address")); in make_v1alpha_request()
131 .serve_with_incoming_shutdown(TcpListenerStream::new(listener), async { in make_v1alpha_request()
H A Dserver.rs100 let listener = tokio::net::TcpListener::bind(addr).await.expect("bind"); in make_test_reflection_request() localVariable
101 let local_addr = format!("http://{}", listener.local_addr().expect("local address")); in make_test_reflection_request()
110 .serve_with_incoming_shutdown(TcpListenerStream::new(listener), async { in make_test_reflection_request()
/tonic/tests/default_stubs/src/
H A Dtest_defaults.rs87 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in run_services_in_background() localVariable
88 let addr = listener.local_addr().unwrap(); in run_services_in_background()
96 .serve_with_incoming(tokio_stream::wrappers::TcpListenerStream::new(listener)) in run_services_in_background()
/tonic/tonic/src/transport/server/
H A Dincoming.rs76 fn from(listener: TcpListener) -> Self { in from()
78 inner: TcpListenerStream::new(listener), in from()
/tonic/tests/web/tests/
H A Dgrpc.rs104 let (listener, url) = bind().await; in grpc()
109 .serve_with_incoming(TcpListenerStream::new(listener)); in grpc()
115 let (listener, url) = bind().await; in grpc_web()
121 .serve_with_incoming(TcpListenerStream::new(listener)); in grpc_web()
H A Dgrpc_web.rs70 let listener = TcpListener::bind(addr).await.expect("listener"); in spawn() localVariable
71 let url = format!("http://{}", listener.local_addr().unwrap()); in spawn()
72 let listener_stream = TcpListenerStream::new(listener); in spawn()
/tonic/examples/src/tls_rustls/
H A Dserver.rs49 let listener = TcpListener::bind("[::1]:50051").await?; in main() localVariable
53 let (conn, addr) = match listener.accept().await { in main()