Struct nats::asynk::Subscription

pub struct Subscription { /* private fields */ }

A subscription to a subject.

Implementations

impl Subscription

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

Gets the next message, or returns None if the subscription has been unsubscribed or the connection is closed.

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 async fn drain(&self) -> Result<()>

Stops listening for new messages, but the remaining queued messages can still be received.

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

Stops listening for new messages and discards the remaining queued messages.

Trait Implementations

impl Debug for Subscription

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

Formats the value using the given formatter.