Trait lapin_futures_rustls::AMQPConnectionExt

pub trait AMQPConnectionExt {
    fn connect(
        &self, 
        handle: &Handle
    ) -> Box<Future<Item = Client<AMQPStream>, Error = Error> + 'static>;
}

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

Required Methods

fn connect(
    &self,
    handle: &Handle
) -> Box<Future<Item = Client<AMQPStream>, Error = Error> + 'static>

Method providing a lapin_futures::client::Client wrapped in a Future using a tokio_code::reactor::Handle.

Implementors

• impl AMQPConnectionExt for AMQPUri