mod error;
mod message;
mod resolve;
mod service;
mod uri;
pub use self::error::{ConnectError, ConnectServiceError};
pub use self::message::{Address, Connect};
pub use self::service::{Connector, ConnectorService};
pub use self::service::{Connector2, ConnectorService2};
use ntex_io::Io;
use ntex_service::cfg::SharedCfg;
pub async fn connect<T, U>(message: U) -> Result<Io, ConnectError>
where
T: Address,
Connect<T>: From<U>,
{
ConnectorService::new().connect(message).await
}
pub async fn connect_with<T, U>(message: U, cfg: SharedCfg) -> Result<Io, ConnectError>
where
T: Address,
Connect<T>: From<U>,
{
ConnectorService::with(cfg).connect(message).await
}