| /tonic/tonic/src/transport/server/ |
| H A D | conn.rs | 71 pub local_addr: Option<SocketAddr>, field
78 pub fn local_addr(&self) -> Option<SocketAddr> { in local_addr() method
79 self.local_addr in local_addr()
93 local_addr: self.local_addr().ok(), in connect_info()
|
| /tonic/tonic-reflection/tests/ |
| H A D | versions.rs | 68 let local_addr = format!("http://{}", listener.local_addr().expect("local address")); in make_v1_request() localVariable
85 let conn = tonic::transport::Endpoint::new(local_addr) in make_v1_request()
125 let local_addr = format!("http://{}", listener.local_addr().expect("local address")); in make_v1alpha_request() localVariable
142 let conn = tonic::transport::Endpoint::new(local_addr) in make_v1alpha_request()
|
| H A D | server.rs | 101 let local_addr = format!("http://{}", listener.local_addr().expect("local address")); in make_test_reflection_request() localVariable
121 let conn = tonic::transport::Endpoint::new(local_addr) in make_test_reflection_request()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | connect_info.rs | 19 assert!(req.local_addr().is_some()); in getting_connect_info()
32 let addr = listener.local_addr().unwrap(); in getting_connect_info()
86 assert!(req.local_addr().is_none()); in unary_call()
|
| H A D | http2_keep_alive.rs | 24 let addr = listener.local_addr().unwrap(); in http2_keepalive_does_not_cause_panics()
54 let addr = listener.local_addr().unwrap(); in http2_keepalive_does_not_cause_panics_on_client_side()
|
| H A D | status.rs | 38 let addr = listener.local_addr().unwrap(); in status_with_details()
96 let addr = listener.local_addr().unwrap(); in status_with_metadata()
167 let addr = listener.local_addr().unwrap(); in status_from_server_stream()
237 let addr = listener.local_addr().unwrap(); in message_and_then_status_from_server_stream()
|
| H A D | connection.rs | 44 let addr = listener.local_addr().unwrap(); in connect_returns_err_via_call_after_connected()
87 let addr = listener.local_addr().unwrap(); in connect_lazy_reconnects_after_first_failure()
|
| H A D | extensions.rs | 43 let addr = listener.local_addr().unwrap(); in setting_extension_from_interceptor()
92 let addr = listener.local_addr().unwrap(); in setting_extension_from_tower()
|
| H A D | user_agent.rs | 28 let addr = listener.local_addr().unwrap(); in writes_user_agent_header()
|
| H A D | interceptor.rs | 27 let addr = listener.local_addr().unwrap(); in interceptor_retrieves_grpc_method()
|
| H A D | http2_max_header_list_size.rs | 34 let addr = format!("http://{}", listener.local_addr().unwrap()); in test_http_max_header_list_size_and_long_errors()
|
| H A D | client_layer.rs | 30 let addr = listener.local_addr().unwrap(); in connect_supports_standard_tower_layers()
|
| H A D | timeout.rs | 80 let addr = listener.local_addr().unwrap(); in run_service_in_background()
|
| H A D | origin.rs | 35 let addr = listener.local_addr().unwrap(); in writes_origin_header()
|
| H A D | routes_builder.rs | 61 let addr = listener.local_addr().unwrap(); in multiple_service_using_routes_builder()
|
| /tonic/tests/default_stubs/src/ |
| H A D | test_defaults.rs | 88 let addr = listener.local_addr().unwrap(); in run_services_in_background()
91 let addr_default_stubs = listener_default_stubs.local_addr().unwrap(); in run_services_in_background()
|
| /tonic/tonic/src/ |
| H A D | request.rs | 215 pub fn local_addr(&self) -> Option<SocketAddr> { in local_addr() method
219 .and_then(|i| i.local_addr()); in local_addr()
225 .and_then(|i| i.get_ref().local_addr()) in local_addr()
|
| /tonic/tests/web/tests/ |
| H A D | grpc_web.rs | 71 let url = format!("http://{}", listener.local_addr().unwrap()); in spawn()
|
| H A D | grpc.rs | 98 let url = format!("http://{}", lis.local_addr().unwrap()); in bind()
|
| /tonic/ |
| H A D | CHANGELOG.md | 164 * **transport:** Add`local_addr` to `Request o` ([#1327](https://github.com/hyperium/tonic/issues/1…
|