pub fn unsubscribe(&self, cmd: UnsubCommand) -> impl Future<Item = (), Error = NatsError> + Send + Sync {
        if let Some(max) = cmd.max_msgs {
            if let Some(mut s) = (*self.rx.subs_tx.write()).get_mut(&cmd.sid) {
                s.max_count = Some(max);
            }
        }

        self.tx.send(Op::UNSUB(cmd))
    }
/// Send a UNSUB command to the server and de-register stream in the multiplexer
///
/// Returns `impl Future<Item = (), Error = NatsError>`
Send a UNSUB command to the server and de-register stream in the multiplexer
Returns `impl Future`
Send a UNSUB command to the server and de - register stream in the multiplexer Returns ` impl Future `
pub fn unsubscribe(&self, cmd: UnsubCommand) -> impl Future<Item = (), Error = NatsError> + Send + Sync {
        if let Some(max) = cmd.max_msgs {
            if let Some(mut s) = (*self.rx.subs_tx.write()).get_mut(&cmd.sid) {
                s.max_count = Some(max);
            }
        }
        self.tx.send(Op::UNSUB(cmd))
    }
pub fn unsubscribe ( & self , cmd : UnsubCommand ) -> impl Future < Item = ( ) , Error = NatsError > + Send + Sync { if let Some ( max ) = cmd . max_msgs { if let Some ( mut s ) = ( * self . rx . subs_tx . write ( ) ) . get_mut ( & cmd . sid ) { s . max_count = Some ( max ) ; } } self . tx . send ( Op :: UNSUB ( cmd ) ) }
Send a UNSUB command to the server and de-register stream in the multiplexer
Returns `impl Future<Item = (), Error = NatsError>`
Send a UNSUB command to the server and de - register stream in the multiplexer Returns ` impl Future<Item = () Error = NatsError > `
&self
cmd
UnsubCommand
&self
cmd
UnsubCommand