Trait AMQPUriTcpExt 

pub trait AMQPUriTcpExt {
    // Required methods
    fn connect_with_config(
        &self,
        config: TLSConfig<'_, '_, '_>,
    ) -> HandshakeResult;
    fn connect_with_config_async<RK: RuntimeKit + Send + Sync>(
        &self,
        config: TLSConfig<'_, '_, '_>,
        runtime: &Runtime<RK>,
    ) -> impl Future<Output = Result<AsyncTcpStream<<RK as Reactor>::TcpStream>>>
       where Self: Sized;

    // Provided methods
    fn connect(&self) -> HandshakeResult
       where Self: Sized { ... }
    fn connect_async<RK: RuntimeKit + Send + Sync>(
        &self,
        runtime: &Runtime<RK>,
    ) -> impl Future<Output = Result<AsyncTcpStream<<RK as Reactor>::TcpStream>>>
       where Self: Sized { ... }
}

Trait providing a method to connect to a TcpStream

Required Methods

fn connect_with_config(&self, config: TLSConfig<'_, '_, '_>) -> HandshakeResult

connect to a TcpStream with the given configuration

fn connect_with_config_async<RK: RuntimeKit + Send + Sync>( &self, config: TLSConfig<'_, '_, '_>, runtime: &Runtime<RK>, ) -> impl Future<Output = Result<AsyncTcpStream<<RK as Reactor>::TcpStream>>>

where Self: Sized,

connect to a TcpStream with the given configuration

Provided Methods

fn connect(&self) -> HandshakeResult

where Self: Sized,

connect to a TcpStream

fn connect_async<RK: RuntimeKit + Send + Sync>( &self, runtime: &Runtime<RK>, ) -> impl Future<Output = Result<AsyncTcpStream<<RK as Reactor>::TcpStream>>>

where Self: Sized,

connect to a TcpStream

Implementations on Foreign Types

impl AMQPUriTcpExt for AMQPUri

fn connect_with_config(&self, config: TLSConfig<'_, '_, '_>) -> HandshakeResult

fn connect_with_config_async<RK: RuntimeKit + Send + Sync>( &self, config: TLSConfig<'_, '_, '_>, runtime: &Runtime<RK>, ) -> impl Future<Output = Result<AsyncTcpStream<<RK as Reactor>::TcpStream>>>

where Self: Sized,

Implementors