Struct PulsarSubscriber 

pub struct PulsarSubscriber { /* private fields */ }

A subscription to one or more Pulsar topics; yields PulsarMessages.

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 Debug for PulsarSubscriber

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

Formats the value using the given formatter.

impl Seekable for PulsarSubscriber

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.