Struct nats::Client
[−]
[src]
pub struct Client { /* fields omitted */ }
Methods
impl Client
[src]
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>
&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>
&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>
&mut self,
subject: &str,
msg: &[u8]
) -> Result<String, NatsError>