Trait rama::tcp::client::TcpStreamConnector

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

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

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].

Object Safety

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 + Send + Sync>>, B: TcpStreamConnector, <B as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>,

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

impl<A, B, C> TcpStreamConnector for Either3<A, B, C>

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

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

impl<A, B, C, D> TcpStreamConnector for Either4<A, B, C, D>

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

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

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 + Send + Sync>>, B: TcpStreamConnector, <B as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, C: TcpStreamConnector, <C as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, D: TcpStreamConnector, <D as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, E: TcpStreamConnector, <E as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>,

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

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 + Send + Sync>>, B: TcpStreamConnector, <B as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, C: TcpStreamConnector, <C as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, D: TcpStreamConnector, <D as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, E: TcpStreamConnector, <E as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, F: TcpStreamConnector, <F as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>,

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

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 + Send + Sync>>, B: TcpStreamConnector, <B as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, C: TcpStreamConnector, <C as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, D: TcpStreamConnector, <D as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, E: TcpStreamConnector, <E as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, F: TcpStreamConnector, <F as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, G: TcpStreamConnector, <G as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>,

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

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 + Send + Sync>>, B: TcpStreamConnector, <B as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, C: TcpStreamConnector, <C as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, D: TcpStreamConnector, <D as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, E: TcpStreamConnector, <E as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, F: TcpStreamConnector, <F as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, G: TcpStreamConnector, <G as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, H: TcpStreamConnector, <H as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>,

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

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 + Send + Sync>>, B: TcpStreamConnector, <B as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, C: TcpStreamConnector, <C as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, D: TcpStreamConnector, <D as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, E: TcpStreamConnector, <E as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, F: TcpStreamConnector, <F as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, G: TcpStreamConnector, <G as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, H: TcpStreamConnector, <H as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>, I: TcpStreamConnector, <I as TcpStreamConnector>::Error: Into<Box<dyn Error + Send + Sync>>,

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

impl<ConnectFn, ConnectFnFut, ConnectFnErr> TcpStreamConnector for ConnectFn

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

type Error = ConnectFnErr