Trait AMQPConnectionTlsExt

pub trait AMQPConnectionTlsExt<TlsStream: AsyncRead + AsyncWrite + Send + Sync + 'static> {
    // Required methods
    fn connect<Connector: FnOnce(String, TcpStream) -> Box<dyn Future<Item = Box<TlsStream>, Error = Error> + Send + 'static> + Send + 'static>(
        self,
        connector: Connector,
    ) -> Box<dyn Future<Item = (Client<AMQPStream<TlsStream>>, HeartbeatHandle, Box<dyn Future<Item = (), Error = Error> + Send + 'static>), Error = Error> + Send + 'static>;
    fn connect_cancellable<Connector: FnOnce(String, TcpStream) -> Box<dyn Future<Item = Box<TlsStream>, Error = Error> + Send + 'static> + Send + 'static, F: FnOnce(Error) + Send + 'static>(
        self,
        heartbeat_error_handler: F,
        connector: Connector,
    ) -> Box<dyn Future<Item = (Client<AMQPStream<TlsStream>>, HeartbeatHandle), Error = Error> + Send + 'static>;
    fn connect_full<Connector: FnOnce(String, TcpStream) -> Box<dyn Future<Item = Box<TlsStream>, Error = Error> + Send + 'static> + Send + 'static>(
        self,
        connector: Connector,
        properties: ConnectionProperties,
    ) -> Box<dyn Future<Item = (Client<AMQPStream<TlsStream>>, HeartbeatHandle, Box<dyn Future<Item = (), Error = Error> + Send + 'static>), Error = Error> + Send + 'static>;
    fn connect_cancellable_full<Connector: FnOnce(String, TcpStream) -> Box<dyn Future<Item = Box<TlsStream>, Error = Error> + Send + 'static> + Send + 'static, F: FnOnce(Error) + Send + 'static>(
        self,
        heartbeat_error_handler: F,
        connector: Connector,
        properties: ConnectionProperties,
    ) -> Box<dyn Future<Item = (Client<AMQPStream<TlsStream>>, HeartbeatHandle), Error = Error> + Send + 'static>;
}

👎Deprecated: use lapin directly instead

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

Required Methods

fn connect<Connector: FnOnce(String, TcpStream) -> Box<dyn Future<Item = Box<TlsStream>, Error = Error> + Send + 'static> + Send + 'static>( self, connector: Connector, ) -> Box<dyn Future<Item = (Client<AMQPStream<TlsStream>>, 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<Connector: FnOnce(String, TcpStream) -> Box<dyn Future<Item = Box<TlsStream>, Error = Error> + Send + 'static> + Send + 'static, F: FnOnce(Error) + Send + 'static>( self, heartbeat_error_handler: F, connector: Connector, ) -> Box<dyn Future<Item = (Client<AMQPStream<TlsStream>>, 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<Connector: FnOnce(String, TcpStream) -> Box<dyn Future<Item = Box<TlsStream>, Error = Error> + Send + 'static> + Send + 'static>( self, connector: Connector, properties: ConnectionProperties, ) -> Box<dyn Future<Item = (Client<AMQPStream<TlsStream>>, 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<Connector: FnOnce(String, TcpStream) -> Box<dyn Future<Item = Box<TlsStream>, Error = Error> + Send + 'static> + Send + 'static, F: FnOnce(Error) + Send + 'static>( self, heartbeat_error_handler: F, connector: Connector, properties: ConnectionProperties, ) -> Box<dyn Future<Item = (Client<AMQPStream<TlsStream>>, 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, TlsStream: AsyncRead + AsyncWrite + Send + Sync + 'static> AMQPConnectionTlsExt<TlsStream> for &'a str

fn connect<Connector: FnOnce(String, TcpStream) -> Box<dyn Future<Item = Box<TlsStream>, Error = Error> + Send + 'static> + Send + 'static>( self, connector: Connector, ) -> Box<dyn Future<Item = (Client<AMQPStream<TlsStream>>, HeartbeatHandle, Box<dyn Future<Item = (), Error = Error> + Send + 'static>), Error = Error> + Send + 'static>

👎Deprecated: use lapin directly instead

fn connect_cancellable<Connector: FnOnce(String, TcpStream) -> Box<dyn Future<Item = Box<TlsStream>, Error = Error> + Send + 'static> + Send + 'static, F: FnOnce(Error) + Send + 'static>( self, heartbeat_error_handler: F, connector: Connector, ) -> Box<dyn Future<Item = (Client<AMQPStream<TlsStream>>, HeartbeatHandle), Error = Error> + Send + 'static>

👎Deprecated: use lapin directly instead

fn connect_full<Connector: FnOnce(String, TcpStream) -> Box<dyn Future<Item = Box<TlsStream>, Error = Error> + Send + 'static> + Send + 'static>( self, connector: Connector, properties: ConnectionProperties, ) -> Box<dyn Future<Item = (Client<AMQPStream<TlsStream>>, HeartbeatHandle, Box<dyn Future<Item = (), Error = Error> + Send + 'static>), Error = Error> + Send + 'static>

👎Deprecated: use lapin directly instead

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

👎Deprecated: use lapin directly instead

Implementors

impl<TlsStream: AsyncRead + AsyncWrite + Send + Sync + 'static> AMQPConnectionTlsExt<TlsStream> for AMQPUri