Searched refs:Connection (Results 1 – 5 of 5) sorted by relevance
| /tonic/tonic/src/transport/channel/service/ |
| H A D | discover.rs | 1 use super::super::{Connection, Endpoint};
32 type Item = Result<TowerChange<K, Connection>, crate::BoxError>;
39 let connection = Connection::lazy(endpoint.http_connector(), endpoint); in poll_next()
|
| H A D | io.rs | 6 use hyper_util::client::legacy::connect::{Connected as HyperConnected, Connection};
23 impl Connection for BoxedIo {
|
| H A D | connection.rs | 23 pub(crate) struct Connection { struct
27 impl Connection { argument
104 impl Service<Request<Body>> for Connection { implementation
118 impl Load for Connection { implementation
126 impl fmt::Debug for Connection { implementation
|
| H A D | mod.rs | 11 pub(super) use self::connection::Connection;
|
| /tonic/tonic/src/transport/channel/ |
| H A D | mod.rs | 13 use self::service::{Connection, DynamicServiceStream, Executor, SharedExec};
160 let svc = Connection::lazy(connector, endpoint); in new()
181 let svc = Connection::connect(connector, endpoint) in connect()
192 D: Discover<Service = Connection> + Unpin + Send + 'static, in balance()
|