Trait AMQPConnectionTlsApiExt

pub trait AMQPConnectionTlsApiExt: AMQPConnectionTlsExt<TlsStream<TcpStream>>
where
    Self: Sized,
{
    // Provided methods
    fn connect<C: TlsConnector + Send + 'static>(
        self,
    ) -> Box<dyn Future<Item = (Client<AMQPStream>, HeartbeatHandle, Box<dyn Future<Item = (), Error = Error> + Send + 'static>), Error = Error> + Send + 'static> { ... }
    fn connect_cancellable<C: TlsConnector + Send + 'static, F: FnOnce(Error) + Send + 'static>(
        self,
        heartbeat_error_handler: F,
    ) -> Box<dyn Future<Item = (Client<AMQPStream>, HeartbeatHandle), Error = Error> + Send + 'static> { ... }
    fn connect_full<C: TlsConnector + Send + 'static>(
        self,
        properties: ConnectionProperties,
    ) -> Box<dyn Future<Item = (Client<AMQPStream>, HeartbeatHandle, Box<dyn Future<Item = (), Error = Error> + Send + 'static>), Error = Error> + Send + 'static> { ... }
    fn connect_cancellable_full<C: TlsConnector + Send + 'static, F: FnOnce(Error) + Send + 'static>(
        self,
        heartbeat_error_handler: F,
        properties: ConnectionProperties,
    ) -> Box<dyn Future<Item = (Client<AMQPStream>, HeartbeatHandle), Error = Error> + Send + 'static> { ... }
}

👎Deprecated: use lapin directly instead

Add a connect method providing a lapin_futures::client::Client wrapped in a Future.

Provided Methods

fn connect<C: TlsConnector + Send + 'static>( self, ) -> Box<dyn Future<Item = (Client<AMQPStream>, HeartbeatHandle, Box<dyn Future<Item = (), Error = Error> + Send + 'static>), Error = Error> + Send + 'static>

👎Deprecated: use lapin directly instead

Method providing a lapin_futures::client::Client, a lapin_futures::client::HeartbeatHandle and a lapin::client::Heartbeat pulse wrapped in a Future

fn connect_cancellable<C: TlsConnector + Send + 'static, F: FnOnce(Error) + Send + 'static>( self, heartbeat_error_handler: F, ) -> Box<dyn Future<Item = (Client<AMQPStream>, HeartbeatHandle), Error = Error> + Send + 'static>

👎Deprecated: use lapin directly instead

Method providing a lapin_futures::client::Client and lapin_futures::client::HeartbeatHandle wrapped in a Future

fn connect_full<C: TlsConnector + Send + 'static>( self, properties: ConnectionProperties, ) -> Box<dyn Future<Item = (Client<AMQPStream>, HeartbeatHandle, Box<dyn Future<Item = (), Error = Error> + Send + 'static>), Error = Error> + Send + 'static>

👎Deprecated: use lapin directly instead

Method providing a lapin_futures::client::Client, a lapin_futures::client::HeartbeatHandle and a lapin::client::Heartbeat pulse wrapped in a Future

fn connect_cancellable_full<C: TlsConnector + Send + 'static, F: FnOnce(Error) + Send + 'static>( self, heartbeat_error_handler: F, properties: ConnectionProperties, ) -> Box<dyn Future<Item = (Client<AMQPStream>, HeartbeatHandle), Error = Error> + Send + 'static>

👎Deprecated: use lapin directly instead

Method providing a lapin_futures::client::Client and lapin_futures::client::HeartbeatHandle wrapped in a Future

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<'a> AMQPConnectionTlsApiExt for &'a str

Implementors

impl AMQPConnectionTlsApiExt for AMQPUri