pub fn send(&self, op: Op) -> impl Future<Item = (), Error = NatsError> {
        //let _verbose = self.verbose.clone();
        self.tx
            .unbounded_send(op)
            .map_err(|_| NatsError::InnerBrokenChain)
            .into_future()
    }
/// Sends an OP to the server
Sends an OP to the server
Sends an OP to the server
pub fn send(&self, op: Op) -> impl Future<Item = (), Error = NatsError> {
        //let _verbose = self.verbose.clone();
        self.tx
            .unbounded_send(op)
            .map_err(|_| NatsError::InnerBrokenChain)
            .into_future()
    }
pub fn send ( & self , op : Op ) -> impl Future < Item = ( ) , Error = NatsError > { //let _verbose = self.verbose.clone(); self . tx . unbounded_send ( op ) . map_err ( | _ | NatsError :: InnerBrokenChain ) . into_future ( ) }
Sends an OP to the server
Sends an OP to the server
&self
op
Op
&self
op
Op