1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
use std::future::Future;
mod error;
mod message;
mod resolve;
mod service;
#[cfg(feature = "http-framework")]
mod uri;
#[cfg(feature = "openssl")]
pub mod openssl;
#[cfg(feature = "rustls")]
pub mod rustls;
use crate::rt::net::TcpStream;
pub use self::error::ConnectError;
pub use self::message::{Address, Connect};
pub use self::resolve::Resolver;
pub use self::service::Connector;
pub fn connect<T, U>(message: U) -> impl Future<Output = Result<TcpStream, ConnectError>>
where
T: Address + 'static,
Connect<T>: From<U>,
{
service::ConnectServiceResponse::new(Box::pin(
Resolver::new().lookup(message.into()),
))
}