Struct PulsarSubscriber 

pub struct PulsarSubscriber { /* private fields */ }

A subscription to one or more Pulsar topics; yields PulsarMessages, one at a time or in batches.

Dropping the subscriber stops the driver task, which closes the client consumer.

Implementations

impl PulsarSubscriber

pub fn topic(&self) -> &str

The topic list or pattern this subscription consumes from.

Trait Implementations

impl BatchSubscriber for PulsarSubscriber

Batches assembled on the client: the client’s consumer yields one delivery at a time, and its batch_size is a flow-control window rather than a receive size, so the buffer in front of the consumer cuts the batches to the size the registration names.

A batch never carries more than the size the registration named - the buffer closes it there - and it carries fewer whenever the deadline elapsed first.

type Batch = Vec<PulsarMessage>

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

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

Returns a stream of batches of at most size messages.

impl Debug for PulsarSubscriber

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

Formats the value using the given formatter.

impl Seekable for PulsarSubscriber

Buffering does not move the subscription, so the handle is the wire subscriber’s own: a batch subscription still opens at a chosen position and still repositions from a handler.

type Seeker = PulsarSeeker

The handle usable while this subscriber’s stream is running.

fn seeker(&self) -> PulsarSeeker

Mints a handle for repositioning this subscription.

impl Subscriber for PulsarSubscriber

type Message = PulsarMessage

The message type yielded by this subscriber.

type Error = PulsarError

The error type yielded by the stream when delivery fails.

fn stream( &mut self, ) -> impl Stream<Item = Result<PulsarMessage, PulsarError>> + Send + '_

Returns a stream of broker deliveries.