Struct PipelinedSubscriber 

pub struct PipelinedSubscriber<Inner, F: Form> { /* private fields */ }

A pipelined subscription: the form’s own subscriber and the window its deliveries settle in.

The window flushes what it still owes when the subscription stops.

Trait Implementations

impl BatchSubscriber for PipelinedSubscriber<RedisSubscriber, StreamForm>

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

Yields one batch per read, size being the read’s COUNT; the batch is one segment of the window, so its settles leave as one XACK.

Cancel safety

As RedisSubscriber’s batches: entries fetched and not yet settled stay pending.

type Batch = Vec<RoundMessage<StreamForm>>

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

impl BatchSubscriber for PipelinedSubscriber<ChannelReader, PubSubForm>

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

Yields a batch of the messages already arrived, up to size; the batch is one segment of the window.

Cancel safety

As a Pub/Sub subscription’s: a message nobody is polling for is lost.

type Batch = Vec<RoundMessage<PubSubForm>>

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

impl BatchSubscriber for PipelinedSubscriber<ListReader, ListForm>

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

Yields one batch per read of up to size entries; the batch is one segment of the window.

Cancel safety

As a list subscription’s batches: on a reliable list an entry claimed and not settled stays on the processing list.

type Batch = Vec<RoundMessage<ListForm>>

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

impl<Inner, F: Form> Debug for PipelinedSubscriber<Inner, F>

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

Formats the value using the given formatter.

impl<Inner, F: Form> Drop for PipelinedSubscriber<Inner, F>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl Seekable for PipelinedSubscriber<RedisSubscriber, StreamForm>

Repositions the consumer group as the subscription without a window does, which is what a mount site’s start_at(..) seeks through.

type Seeker = RedisGroupSeeker

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

fn seeker(&self) -> RedisGroupSeeker

Mints a handle for repositioning this subscription.

impl Subscriber for PipelinedSubscriber<RedisSubscriber, StreamForm>

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

Yields one delivery per entry, each with a slot in the window.

Cancel safety

As RedisSubscriber’s: entries fetched and not yet settled stay pending.

type Message = RoundMessage<StreamForm>

The message type yielded by this subscriber.

type Error = RedisError

The error type yielded by the stream when delivery fails.

impl Subscriber for PipelinedSubscriber<ChannelReader, PubSubForm>

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

Yields one delivery per message, each with a slot in the window.

Cancel safety

As a Pub/Sub subscription’s: a message nobody is polling for is lost.

type Message = RoundMessage<PubSubForm>

The message type yielded by this subscriber.

type Error = RedisError

The error type yielded by the stream when delivery fails.

impl Subscriber for PipelinedSubscriber<ListReader, ListForm>

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

Yields one delivery per entry, each with a slot in the window, claiming the read’s COUNT at a time.

Cancel safety

As RedisListSubscriber’s: on a reliable list an entry claimed and not settled stays on the processing list.

type Message = RoundMessage<ListForm>

The message type yielded by this subscriber.

type Error = RedisError

The error type yielded by the stream when delivery fails.