Searched refs:TcpIncoming (Results 1 – 14 of 14) sorted by relevance
| /tonic/tonic/src/transport/server/ |
| H A D | incoming.rs | 18 pub struct TcpIncoming { struct
24 impl TcpIncoming { impl
75 impl From<TcpListener> for TcpIncoming { implementation
85 impl Stream for TcpIncoming { implementation
121 use crate::transport::server::TcpIncoming;
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 | 39 pub use incoming::TcpIncoming;
538 fn bind_incoming(&self, addr: SocketAddr) -> Result<TcpIncoming, super::Error> { in bind_incoming() argument
539 Ok(TcpIncoming::bind(addr) in bind_incoming()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | http2_keep_alive.rs | 6 use tonic::transport::{server::TcpIncoming, Channel, Server};
25 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); 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()
|
| H A D | user_agent.rs | 5 transport::{server::TcpIncoming, Endpoint, Server},
29 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in writes_user_agent_header()
|
| H A D | interceptor.rs | 5 transport::{server::TcpIncoming, Endpoint, Server},
28 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in interceptor_retrieves_grpc_method()
|
| H A D | client_layer.rs | 6 transport::{server::TcpIncoming, Endpoint, Server},
31 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in connect_supports_standard_tower_layers()
|
| H A D | connection.rs | 6 transport::{server::TcpIncoming, Endpoint, Server},
45 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); 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()
|
| H A D | status.rs | 14 transport::{server::TcpIncoming, Endpoint, Server},
39 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in status_with_details()
97 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in status_with_metadata()
168 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in status_from_server_stream()
238 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in message_and_then_status_from_server_stream()
|
| H A D | extensions.rs | 13 transport::{server::TcpIncoming, Endpoint, Server},
44 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in setting_extension_from_interceptor()
93 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in setting_extension_from_tower()
|
| H A D | origin.rs | 10 transport::{server::TcpIncoming, Endpoint, Server},
36 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in writes_origin_header()
|
| H A D | routes_builder.rs | 11 use tonic::transport::server::TcpIncoming;
62 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in multiple_service_using_routes_builder()
|
| H A D | connect_info.rs | 6 server::{TcpConnectInfo, TcpIncoming},
33 let incoming = TcpIncoming::from(listener).with_nodelay(Some(true)); in getting_connect_info()
|
| H A D | http2_max_header_list_size.rs | 38 let listener = tonic::transport::server::TcpIncoming::from(listener) in test_http_max_header_list_size_and_long_errors()
|
| /tonic/ |
| H A D | CHANGELOG.md | 203 * **transport:** add `from_listener` for `TcpIncoming` ([#1093](https://github.com/hyperium/tonic/i…
|