Searched refs:connector (Results 1 – 6 of 6) sorted by relevance
| /tonic/tonic/src/transport/channel/ |
| H A D | endpoint.rs | 346 self.connector(http) in http_connector()
376 let connector = self.connector(connector); in connect_with_connector() localVariable
379 let mut connector = hyper_timeout::TimeoutConnector::new(connector); in connect_with_connector() localVariable
380 connector.set_connect_timeout(Some(connect_timeout)); in connect_with_connector()
381 Channel::connect(connector, self.clone()).await in connect_with_connector()
383 Channel::connect(connector, self.clone()).await in connect_with_connector()
401 let connector = self.connector(connector); in connect_with_connector_lazy() localVariable
403 let mut connector = hyper_timeout::TimeoutConnector::new(connector); in connect_with_connector_lazy() localVariable
404 connector.set_connect_timeout(Some(connect_timeout)); in connect_with_connector_lazy()
405 Channel::new(connector, self.clone()) in connect_with_connector_lazy()
[all …]
|
| H A D | mod.rs | 150 pub fn new<C>(connector: C, endpoint: Endpoint) -> Self in new()
160 let svc = Connection::lazy(connector, endpoint); in new()
171 pub async fn connect<C>(connector: C, endpoint: Endpoint) -> Result<Self, super::Error> in connect()
181 let svc = Connection::connect(connector, endpoint) in connect()
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | connection.rs | 28 fn new<C>(connector: C, endpoint: Endpoint, is_lazy: bool) -> Self in new()
71 MakeSendRequestService::new(connector, endpoint.executor.clone(), settings); in new()
81 connector: C, in connect()
90 Self::new(connector, endpoint, false).ready_oneshot().await in connect()
93 pub(crate) fn lazy<C>(connector: C, endpoint: Endpoint) -> Self in lazy()
100 Self::new(connector, endpoint, true) in lazy()
159 connector: C, field
165 fn new(connector: C, executor: SharedExec, settings: Builder<SharedExec>) -> Self { in new()
167 connector, in new()
186 self.connector.poll_ready(cx).map_err(Into::into) in poll_ready()
[all …]
|
| H A D | mod.rs | 20 mod connector; module
21 pub(crate) use self::connector::Connector;
|
| /tonic/examples/src/tls_rustls/ |
| H A D | client.rs | 37 let connector = tower::ServiceBuilder::new() in main() localVariable
53 let client = hyper_util::client::legacy::Client::builder(TokioExecutor::new()).build(connector); in main()
|
| /tonic/ |
| H A D | CHANGELOG.md | 282 * **transport:** connect w/ connector infailable ([#922](https://github.com/hyperium/tonic/issues/9…
528 * **transport:** Apply tls-connector for discovery when applicable ([#334](https://github.com/hyper…
|