pub fn connect(self) -> impl Future<Item = Self, Error = NatsError> + Send + Sync {
        self.tx
            .send(Op::CONNECT(self.opts.connect_command.clone()))
            .and_then(move |_| future::ok(self))
    }
/// Sends the CONNECT command to the server to setup connection
///
/// Returns `impl Future<Item = Self, Error = NatsError>`
Sends the CONNECT command to the server to setup connection
Returns `impl Future`
Sends the CONNECT command to the server to setup connection Returns ` impl Future `
pub fn connect(self) -> impl Future<Item = Self, Error = NatsError> + Send + Sync {
        self.tx
            .send(Op::CONNECT(self.opts.connect_command.clone()))
            .and_then(move |_| future::ok(self))
    }
pub fn connect ( self ) -> impl Future < Item = Self , Error = NatsError > + Send + Sync { self . tx . send ( Op :: CONNECT ( self . opts . connect_command . clone ( ) ) ) . and_then ( move | _ | future :: ok ( self ) ) }
Sends the CONNECT command to the server to setup connection
Returns `impl Future<Item = Self, Error = NatsError>`
Sends the CONNECT command to the server to setup connection Returns ` impl Future<Item = Self Error = NatsError > `
self
self