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::service::{Connector, ConnectorService};
11
12use ntex_io::Io;
13use ntex_service::cfg::SharedCfg;
14
15pub async fn connect<T, U>(message: U) -> Result<Io, ConnectError>
17where
18 T: Address,
19 Connect<T>: From<U>,
20{
21 ConnectorService::new().connect(message).await
22}
23
24pub async fn connect_with<T, U>(message: U, cfg: SharedCfg) -> Result<Io, ConnectError>
26where
27 T: Address,
28 Connect<T>: From<U>,
29{
30 ConnectorService::with(cfg).connect(message).await
31}