Struct LapinSubscriber 

pub struct LapinSubscriber { /* private fields */ }

A consumer on one queue, yielding LapinMessage deliveries.

Created by subscribing a RabbitQueue descriptor (or a bare queue name) through LapinBroker. The subscriber owns a dedicated channel; dropping it closes that channel and the broker redelivers whatever was unacknowledged.

Back-pressure: the broker stops pushing once prefetch unacknowledged deliveries are in flight, so consuming slower slows the producer side down instead of buffering without bound.

Implementations

impl LapinSubscriber

pub fn queue(&self) -> &str

The queue this subscriber consumes from.

Trait Implementations

impl Debug for LapinSubscriber

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

Formats the value using the given formatter.

impl Subscriber for LapinSubscriber

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

Streams deliveries as they arrive; the stream ends when the consumer is cancelled or the connection closes.

Cancel safety

Polling is cancel safe (no delivery is lost by dropping the stream between polls), and the stream can be re-created by calling stream again: deliveries buffer in the consumer, not in the returned stream.

type Message = LapinMessage

The message type yielded by this subscriber.

type Error = AmqpError

The error type yielded by the stream when delivery fails.