Trait AMQPUriTcpExt 

pub trait AMQPUriTcpExt {
    // Required methods
    fn connect_with_config(
        &self,
        config: TLSConfig<'_, '_, '_>,
    ) -> HandshakeResult;
    fn connect_with_config_async<'life0, 'life1, 'life2, 'life3, 'async_trait, R, E>(
        &'life0 self,
        config: TLSConfig<'life1, 'life2, 'life3>,
        reactor: R,
        executor: E,
    ) -> Pin<Box<dyn Future<Output = Result<AsyncTcpStream>> + Send + 'async_trait>>
       where R::Target: TcpReactor + Send + Sync,
             E::Target: BlockingExecutor + Send + Sync,
             R: 'async_trait + Deref + Send + Sync,
             E: 'async_trait + Deref + Send + Sync,
             Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;

    // Provided methods
    fn connect(&self) -> HandshakeResult
       where Self: Sized { ... }
    fn connect_async<'life0, 'async_trait, R, E>(
        &'life0 self,
        reactor: R,
        executor: E,
    ) -> Pin<Box<dyn Future<Output = Result<AsyncTcpStream>> + Send + 'async_trait>>
       where Self: Sized + Sync + 'async_trait,
             R::Target: TcpReactor + Send + Sync,
             E::Target: BlockingExecutor + Send + Sync,
             R: 'async_trait + Deref + Send + Sync,
             E: 'async_trait + Deref + Send + Sync,
             'life0: 'async_trait { ... }
}

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<'life0, 'life1, 'life2, 'life3, 'async_trait, R, E>( &'life0 self, config: TLSConfig<'life1, 'life2, 'life3>, reactor: R, executor: E, ) -> Pin<Box<dyn Future<Output = Result<AsyncTcpStream>> + Send + 'async_trait>>

where R::Target: TcpReactor + Send + Sync, E::Target: BlockingExecutor + Send + Sync, R: 'async_trait + Deref + Send + Sync, E: 'async_trait + Deref + Send + Sync, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

connect to a TcpStream with the given configuration

Provided Methods

fn connect(&self) -> HandshakeResult

where Self: Sized,

connect to a TcpStream

fn connect_async<'life0, 'async_trait, R, E>( &'life0 self, reactor: R, executor: E, ) -> Pin<Box<dyn Future<Output = Result<AsyncTcpStream>> + Send + 'async_trait>>

where Self: Sized + Sync + 'async_trait, R::Target: TcpReactor + Send + Sync, E::Target: BlockingExecutor + Send + Sync, R: 'async_trait + Deref + Send + Sync, E: 'async_trait + Deref + Send + Sync, 'life0: 'async_trait,

connect to 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 AMQPUriTcpExt for AMQPUri

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

fn connect_with_config_async<'life0, 'life1, 'life2, 'life3, 'async_trait, R, E>( &'life0 self, config: TLSConfig<'life1, 'life2, 'life3>, reactor: R, executor: E, ) -> Pin<Box<dyn Future<Output = Result<AsyncTcpStream>> + Send + 'async_trait>>

where R::Target: TcpReactor + Send + Sync, E::Target: BlockingExecutor + Send + Sync, R: 'async_trait + Deref + Send + Sync, E: 'async_trait + Deref + Send + Sync, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Implementors