Trait lapin_async::tcp::AMQPUriTcpExt

pub trait AMQPUriTcpExt {
    fn connect<S, F>(self, f: F) -> Result<S, Error>
    where
        F: FnOnce(TcpStream, AMQPUri) -> S;
}

Trait providing a method to connect to a TcpStream

Required methods

fn connect<S, F>(self, f: F) -> Result<S, Error> where
    F: FnOnce(TcpStream, AMQPUri) -> S, 

connect to a TcpStream

Loading content...

Implementations on Foreign Types

impl<'_> AMQPUriTcpExt for &'_ str

fn connect<S, F>(self, f: F) -> Result<S, Error> where
    F: FnOnce(TcpStream, AMQPUri) -> S, 

Loading content...

Implementors

impl AMQPUriTcpExt for AMQPUri

fn connect<S, F>(self, f: F) -> Result<S, Error> where
    F: FnOnce(TcpStream, AMQPUri) -> S, 

Loading content...