Trait amq_protocol_tcp::AMQPUriTcpExt

pub trait AMQPUriTcpExt {
    fn connect_full<S, F: FnOnce(TcpStream, AMQPUri, Option<(Poll, Token)>) -> S>(
        self, 
        f: F, 
        poll: Option<(Poll, Token)>, 
        identity: Option<Identity>
    ) -> Result<S>;

    fn connect<S, F: FnOnce(TcpStream, AMQPUri, Option<(Poll, Token)>) -> S>(
        self, 
        f: F
    ) -> Result<S>
    where
        Self: Sized,
    { ... }
}

Trait providing a method to connect to a TcpStream

Required methods

fn connect_full<S, F: FnOnce(TcpStream, AMQPUri, Option<(Poll, Token)>) -> S>(
    self,
    f: F,
    poll: Option<(Poll, Token)>,
    identity: Option<Identity>
) -> Result<S>

connect to a TcpStream, registering it to the given Poll with the given Token to handle the handshake process. You should reregister it afterwards to better fit your needs

Loading content...

Provided methods

fn connect<S, F: FnOnce(TcpStream, AMQPUri, Option<(Poll, Token)>) -> S>(
    self,
    f: F
) -> Result<S> where
    Self: Sized, 

connect to a TcpStream

Loading content...

Implementations on Foreign Types

impl AMQPUriTcpExt for AMQPUri

fn connect_full<S, F: FnOnce(TcpStream, AMQPUri, Option<(Poll, Token)>) -> S>(
    self,
    f: F,
    poll: Option<(Poll, Token)>,
    identity: Option<Identity>
) -> Result<S>

impl<'_> AMQPUriTcpExt for &'_ str

fn connect_full<S, F: FnOnce(TcpStream, AMQPUri, Option<(Poll, Token)>) -> S>(
    self,
    f: F,
    poll: Option<(Poll, Token)>,
    identity: Option<Identity>
) -> Result<S>

Loading content...

Implementors

Loading content...