Struct nats::subscription::Subscription

pub struct Subscription { /* fields omitted */ }

A Subscription receives Messages published to specific NATS Subjects.

Methods

impl Subscription

pub fn next(&self) -> Option<Message>

Get the next message, or None if the subscription has been unsubscribed or the connection closed.

Example

if let Some(msg) = sub.next() {}

pub fn try_next(&self) -> Option<Message>

Try to get the next message, or None if no messages are present or if the subscription has been unsubscribed or the connection closed.

Example

if let Some(msg) = sub.try_next() {
  println!("Received {}", msg);
}

pub fn next_timeout(
    &self,
    timeout: Duration
) -> Result<Message, RecvTimeoutError>

Get the next message, or a timeout error if no messages are available for timout.

Example

if let Ok(msg) = sub.next_timeout(std::time::Duration::from_secs(1)) {}

pub const fn messages(&self) -> Iter

Returns a blocking message iterator. Same as calling iter().

Example

for msg in sub.messages() {}

pub const fn iter(&self) -> Iter

Returns a blocking message iterator.

Example

for msg in sub.iter() {}

pub const fn try_iter(&self) -> TryIter

Returns a non-blocking message iterator.

Example

for msg in sub.try_iter() {}

pub const fn timeout_iter(&self, timeout: Duration) -> TimeoutIter

Returns a blocking message iterator with a time deadline for blocking.

Example

for msg in sub.timeout_iter(std::time::Duration::from_secs(1)) {}

pub fn with_handler<F>(self, handler: F) -> Handler where
    F: Fn(Message) -> Result<()> + Sync + Send + 'static, 

Attach a closure to handle messages. This closure will execute in a separate thread. The result of this call is a Handler which can not be iterated and must be unsubscribed or closed directly to unregister interest. A Handler will not unregister interest with the server when drop(&mut self) is called.

Example

nc.subscribe("bar")?.with_handler(move |msg| {
    println!("Received {}", &msg);
    Ok(())
});

pub fn unsubscribe(self) -> Result<()>

Unsubscribe a subscription.

Example

let sub = nc.subscribe("foo")?;
sub.unsubscribe()?;

pub fn close(self) -> Result<()>

Close a subscription. Same as unsubscribe

Example

let sub = nc.subscribe("foo")?;
sub.close()?;

Trait Implementations

impl Clone for Subscription

fn clone(&self) -> Subscription

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Subscription

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

Formats the value using the given formatter.

impl Drop for Subscription

fn drop(&mut self)

Executes the destructor for this type.

impl IntoIterator for Subscription

type Item = Message

The type of the elements being iterated over.

type IntoIter = IntoIter

Which kind of iterator are we turning this into?

fn into_iter(self) -> IntoIter

Creates an iterator from a value.

impl<'a> IntoIterator for &'a Subscription

type Item = Message

The type of the elements being iterated over.

type IntoIter = Iter<'a>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Iter<'a>

Creates an iterator from a value.