rama::tcp::client

Trait TcpStreamConnector

pub trait TcpStreamConnector:
    Clone
    + Send
    + Sync
    + 'static {
    type Error;

    // Required method
    fn connect(
        &self,
        addr: SocketAddr,
    ) -> impl Future<Output = Result<TcpStream, Self::Error>> + Send;
}
Expand description

Trait used internally by tcp_connect and the TcpConnector to actually establish the [TcpStream.]

Required Associated Types§

type Error

Type of error that can occurr when establishing the connection failed.

Required Methods§

fn connect( &self, addr: SocketAddr, ) -> impl Future<Output = Result<TcpStream, Self::Error>> + Send

Connect to the target via the given SocketAddress to establish a TcpStream.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types§

§

impl TcpStreamConnector for ()

§

type Error = Error

§

fn connect( &self, addr: SocketAddr, ) -> impl Future<Output = Result<TcpStream, <() as TcpStreamConnector>::Error>> + Send

§

impl<T> TcpStreamConnector for Arc<T>
where T: TcpStreamConnector,

§

type Error = <T as TcpStreamConnector>::Error

§

fn connect( &self, addr: SocketAddr, ) -> impl Future<Output = Result<TcpStream, <Arc<T> as TcpStreamConnector>::Error>> + Send

Implementors§

§

impl<A, B> TcpStreamConnector for Either<A, B>
where A: TcpStreamConnector, <A as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, B: TcpStreamConnector, <B as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>,

§

type Error = Box<dyn Error + Sync + Send>

§

impl<A, B, C> TcpStreamConnector for Either3<A, B, C>
where A: TcpStreamConnector, <A as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, B: TcpStreamConnector, <B as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, C: TcpStreamConnector, <C as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>,

§

type Error = Box<dyn Error + Sync + Send>

§

impl<A, B, C, D> TcpStreamConnector for Either4<A, B, C, D>
where A: TcpStreamConnector, <A as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, B: TcpStreamConnector, <B as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, C: TcpStreamConnector, <C as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, D: TcpStreamConnector, <D as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>,

§

type Error = Box<dyn Error + Sync + Send>

§

impl<A, B, C, D, E> TcpStreamConnector for Either5<A, B, C, D, E>
where A: TcpStreamConnector, <A as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, B: TcpStreamConnector, <B as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, C: TcpStreamConnector, <C as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, D: TcpStreamConnector, <D as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, E: TcpStreamConnector, <E as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>,

§

type Error = Box<dyn Error + Sync + Send>

§

impl<A, B, C, D, E, F> TcpStreamConnector for Either6<A, B, C, D, E, F>
where A: TcpStreamConnector, <A as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, B: TcpStreamConnector, <B as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, C: TcpStreamConnector, <C as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, D: TcpStreamConnector, <D as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, E: TcpStreamConnector, <E as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, F: TcpStreamConnector, <F as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>,

§

type Error = Box<dyn Error + Sync + Send>

§

impl<A, B, C, D, E, F, G> TcpStreamConnector for Either7<A, B, C, D, E, F, G>
where A: TcpStreamConnector, <A as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, B: TcpStreamConnector, <B as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, C: TcpStreamConnector, <C as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, D: TcpStreamConnector, <D as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, E: TcpStreamConnector, <E as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, F: TcpStreamConnector, <F as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, G: TcpStreamConnector, <G as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>,

§

type Error = Box<dyn Error + Sync + Send>

§

impl<A, B, C, D, E, F, G, H> TcpStreamConnector for Either8<A, B, C, D, E, F, G, H>
where A: TcpStreamConnector, <A as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, B: TcpStreamConnector, <B as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, C: TcpStreamConnector, <C as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, D: TcpStreamConnector, <D as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, E: TcpStreamConnector, <E as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, F: TcpStreamConnector, <F as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, G: TcpStreamConnector, <G as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, H: TcpStreamConnector, <H as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>,

§

type Error = Box<dyn Error + Sync + Send>

§

impl<A, B, C, D, E, F, G, H, I> TcpStreamConnector for Either9<A, B, C, D, E, F, G, H, I>
where A: TcpStreamConnector, <A as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, B: TcpStreamConnector, <B as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, C: TcpStreamConnector, <C as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, D: TcpStreamConnector, <D as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, E: TcpStreamConnector, <E as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, F: TcpStreamConnector, <F as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, G: TcpStreamConnector, <G as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, H: TcpStreamConnector, <H as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>, I: TcpStreamConnector, <I as TcpStreamConnector>::Error: Into<Box<dyn Error + Sync + Send>>,

§

type Error = Box<dyn Error + Sync + Send>

§

impl<ConnectFn, ConnectFnFut, ConnectFnErr> TcpStreamConnector for ConnectFn
where ConnectFn: FnOnce(SocketAddr) -> ConnectFnFut + Clone + Send + Sync + 'static, ConnectFnFut: Future<Output = Result<TcpStream, ConnectFnErr>> + Send + 'static, ConnectFnErr: Into<Box<dyn Error + Sync + Send>> + Send + 'static,

§

type Error = ConnectFnErr