| /tonic/tonic/src/transport/server/ |
| H A D | incoming.rs | 56 pub fn bind(addr: SocketAddr) -> std::io::Result<Self> { in bind() method
57 let std_listener = StdTcpListener::bind(addr)?; in bind()
126 let _t1 = TcpIncoming::bind(addr).unwrap(); in one_tcpincoming_at_a_time()
127 let _t2 = TcpIncoming::bind(addr).unwrap_err(); in one_tcpincoming_at_a_time()
129 let _t3 = TcpIncoming::bind(addr).unwrap(); in one_tcpincoming_at_a_time()
|
| H A D | mod.rs | 539 Ok(TcpIncoming::bind(addr) in bind_incoming()
|
| /tonic/tests/web/tests/ |
| H A D | grpc.rs | 95 async fn bind() -> (TcpListener, String) { in bind() function
97 let lis = TcpListener::bind(addr).await.expect("listener"); in bind()
104 let (listener, url) = bind().await; in grpc()
115 let (listener, url) = bind().await; in grpc_web()
|
| H A D | grpc_web.rs | 70 let listener = TcpListener::bind(addr).await.expect("listener"); in spawn()
|
| /tonic/tests/default_stubs/src/ |
| H A D | test_defaults.rs | 87 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in run_services_in_background()
90 let listener_default_stubs = TcpListener::bind("127.0.0.1:0").await.unwrap(); in run_services_in_background()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | http2_keep_alive.rs | 23 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); 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()
|
| H A D | status.rs | 37 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in status_with_details()
95 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in status_with_metadata()
166 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); 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()
|
| H A D | connection.rs | 43 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); 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()
|
| H A D | connect_info.rs | 31 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in getting_connect_info()
101 let uds = UnixListener::bind(&unix_socket_path).unwrap(); in getting_connect_info()
|
| H A D | extensions.rs | 42 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in setting_extension_from_interceptor()
91 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in setting_extension_from_tower()
|
| H A D | user_agent.rs | 27 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in writes_user_agent_header()
|
| H A D | interceptor.rs | 26 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in interceptor_retrieves_grpc_method()
|
| H A D | http2_max_header_list_size.rs | 33 let listener = tokio::net::TcpListener::bind("127.0.0.1:0").await.unwrap(); in test_http_max_header_list_size_and_long_errors()
|
| H A D | client_layer.rs | 29 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in connect_supports_standard_tower_layers()
|
| H A D | timeout.rs | 79 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in run_service_in_background()
|
| H A D | origin.rs | 34 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in writes_origin_header()
|
| H A D | routes_builder.rs | 60 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in multiple_service_using_routes_builder()
|
| /tonic/tonic-reflection/tests/ |
| H A D | versions.rs | 67 let listener = tokio::net::TcpListener::bind(addr).await.expect("bind"); in make_v1_request()
124 let listener = tokio::net::TcpListener::bind(addr).await.expect("bind"); in make_v1alpha_request()
|
| H A D | server.rs | 100 let listener = tokio::net::TcpListener::bind(addr).await.expect("bind"); in make_test_reflection_request()
|
| /tonic/examples/src/uds/ |
| H A D | server.rs | 52 let uds = UnixListener::bind(path)?; in main()
|
| /tonic/examples/src/tls_rustls/ |
| H A D | server.rs | 49 let listener = TcpListener::bind("[::1]:50051").await?; in main()
|
| /tonic/examples/src/h2c/ |
| H A D | server.rs | 41 let incoming = TcpListener::bind(addr).await?; in main()
|