pub fn negotiate(&self, io: IoBoxed) -> impl Future<Output = Result<Client, ConnectError>> {
        trace!("Negotiation client protocol id: Amqp");

        io.set_memory_pool(self.pool);
        io.set_disconnect_timeout(self.disconnect_timeout.into());

        _connect_plain(io, self.config.clone())
    }
/// Negotiate amqp protocol over opened socket
Negotiate amqp protocol over opened socket
Negotiate amqp protocol over opened socket
pub fn negotiate(&self, io: IoBoxed) -> impl Future<Output = Result<Client, ConnectError>> {
        trace!("Negotiation client protocol id: Amqp");
        io.set_memory_pool(self.pool);
        io.set_disconnect_timeout(self.disconnect_timeout.into());
        _connect_plain(io, self.config.clone())
    }
pub fn negotiate ( & self , io : IoBoxed ) -> impl Future < Output = Result < Client , ConnectError > > { trace ! ( " " ) ; io . set_memory_pool ( self . pool ) ; io . set_disconnect_timeout ( self . disconnect_timeout . into ( ) ) ; _connect_plain ( io , self . config . clone ( ) ) }
Negotiate amqp protocol over opened socket
Negotiate amqp protocol over opened socket
&self
io
IoBoxed
&self
io
IoBoxed