Skip to main content

ntex_net/connect/
mod.rs

1//! DNS-aware TCP connector service.
2use ntex_error::Error;
3
4mod error;
5mod message;
6mod resolve;
7mod service;
8mod uri;
9
10pub use self::error::ConnectError;
11pub use self::message::{Address, Connect};
12pub use self::service::Connector;
13
14use ntex_io::Io;
15use ntex_service::cfg::SharedCfg;
16
17/// Resolves a request and connects using default shared configuration.
18pub async fn connect<A, U>(message: U) -> Result<Io, Error<ConnectError>>
19where
20    A: Address,
21    Connect<A>: From<U>,
22{
23    Connector::<A>::new()
24        .connect(message, &SharedCfg::default())
25        .await
26}
27
28/// Resolves a request and connects using the supplied shared configuration.
29pub async fn connect_with<A, U>(message: U, cfg: &SharedCfg) -> Result<Io, Error<ConnectError>>
30where
31    A: Address,
32    Connect<A>: From<U>,
33{
34    Connector::<A>::new().connect(message, cfg).await
35}