Struct nats::Client

pub struct Client {
    // some fields omitted
}

Methods

impl Client

fn new<T: ToStringVec>(uris: T) -> Result<Client, NatsError>

fn set_synchronous(&mut self, synchronous: bool)

fn set_name(&mut self, name: &str)

fn subscribe(&mut self, subject: &str, queue: Option<&str>) -> Result<Channel, NatsError>

fn unsubscribe(&mut self, channel: Channel) -> Result<(), NatsError>

fn unsubscribe_after(&mut self, channel: Channel, max: u64) -> Result<(), NatsError>

fn publish(&mut self, subject: &str, msg: &[u8]) -> Result<(), NatsError>

fn make_request(&mut self, subject: &str, msg: &[u8]) -> Result<String, NatsError>

fn wait(&mut self) -> Result<Event, NatsError>

fn events(&mut self) -> Events

Trait Implementations

impl Debug for Client

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.