Struct Client 

pub struct Client { /* private fields */ }

NATS Streaming client

Implementations

impl Client

pub fn start( nats_connection: Connection, cluster_id: &str, client_id: &str, ) -> Result<Client>

Start a new client, establishing a new NATS Streaming connection, Same as stan::connect().

Example:

    let nats_url = "nats://127.0.0.1:4222";
    let nc = nats::connect(nats_url)?;
    let sc = stan::Client::start(nc, "test-cluster", "rust-client-1")?;

pub fn publish(&self, subject: &str, msg: impl AsRef<[u8]>) -> Result<()>

Publish to a given subject. Will return an error if failed to receive a ack back from the streaming server.

Example:

 fn main() -> io::Result<()> {
    let nats_url = "nats://127.0.0.1:4222";
    let nc = nats::connect(nats_url)?;
    sc.publish("foo", "hello from rust 1")

pub fn subscribe( &self, subject: &str, config: SubscriptionConfig<'_>, ) -> Result<Subscription>

Start a subscription.

Example:

 use nats;
 use std::{io, str::from_utf8};
 fn main() -> io::Result<()> {
    let nats_url = "nats://127.0.0.1:4222";
    let nc = nats::connect(nats_url)?;
    let sc = stan::connect(nc, "test-cluster", "rust-client-1")?;

    sc.publish("foo", "hello from rust 1")?;

    let sub = sc
        .subscribe("foo", Default::default())?
        .with_handler(|msg| {
            println!("{:?}", from_utf8(&msg.data));
            Ok(())
        });

    sc.publish("foo", "hello from rust 2")?;
    sc.publish("foo", "hello from rust 3")
 }

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Client

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.