1mod error;
3mod message;
4mod resolve;
5mod service;
6mod uri;
7
8pub use self::error::{ConnectError, ConnectServiceError};
9pub use self::message::{Address, Connect};
10pub use self::resolve::Resolver;
11pub use self::service::Connector;
12
13use ntex_io::Io;
14use ntex_service::cfg::SharedCfg;
15
16pub async fn connect<T, U>(message: U) -> Result<Io, ConnectError>
18where
19 T: Address,
20 Connect<T>: From<U>,
21{
22 Connector::new().connect(message).await
23}
24
25pub async fn connect_with<T, U>(message: U, cfg: SharedCfg) -> Result<Io, ConnectError>
27where
28 T: Address,
29 Connect<T>: From<U>,
30{
31 Connector::with(cfg).connect(message).await
32}