Struct NatsSubscriber 

pub struct NatsSubscriber { /* private fields */ }

A NATS subscription.

Backed transparently by either a Core subscription (no ack) or a JetStream pull consumer (full ack/nack/term). Construct via crate::NatsBroker::subscribe with crate::SubscribeOptions.

Trait Implementations

impl BatchSubscriber for NatsSubscriber

fn batches( &mut self, ) -> impl Stream<Item = Result<Self::Batch, Self::Error>> + Send + '_

Returns a stream of message batches.

JetStream batches natively: one stream item is one fetch of up to pull_batch messages, waiting at most pull_expires before delivering a partial batch (an empty fetch is retried, so the stream never yields empty batches). Core NATS has no wire-level batching; there a batch is whatever the client has already buffered locally (at least one message, at most [CORE_BATCH_LIMIT]), with no added latency.

Drive a subscriber through either Subscriber::stream or batches, not both at once: on JetStream each issues its own pull requests, so deliveries would be split between them.

Cancel safety

Dropping the returned stream between items is allowed. On JetStream, dropping it mid-fetch can leave already-fetched, undelivered messages to be redelivered after the consumer’s ack_wait.

type Batch = Vec<NatsMessage>

Container yielded by batches. Implementations choose between Vec, custom iterators, or anything else that yields the underlying Subscriber::Message.

impl Debug for NatsSubscriber

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

Formats the value using the given formatter.

impl Subscriber for NatsSubscriber

type Message = NatsMessage

The message type yielded by this subscriber.

type Error = NatsError

The error type yielded by the stream when delivery fails.

fn stream( &mut self, ) -> impl Stream<Item = Result<Self::Message, Self::Error>> + Send + '_

Returns a stream of broker deliveries.