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

        let config = self.config.clone();
        io.set_memory_pool(self.pool);
        io.set_disconnect_timeout(self.disconnect_timeout.into());

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