Struct RecvBatch 

pub struct RecvBatch<T: CommitToken> {
    pub messages: Vec<Message<T>>,
    pub dlq_entries: Vec<FilteredDlqEntry>,
    pub filtered_tokens: Vec<T>,
}

Available on crate feature transport only.

Result of a TransportReceiver::recv call.

Carries passing messages AND any filter-routed DLQ entries in one struct, so a caller cannot lose dead-letters by forgetting a separate drain step. The caller routes dlq_entries onward via its own DLQ handle.

Fields

messages: Vec<Message<T>>

Messages that passed all inbound filters (or had no filter match).

dlq_entries: Vec<FilteredDlqEntry>

Entries matched by action: dlq inbound filters. Caller routes to DLQ.

filtered_tokens: Vec<T>

Commit tokens of messages removed by inbound drop/dlq filters.

Handled records that produced no passing message. Carried into WorkBatch.commit_tokens so the block commit advances the source past them – otherwise an all-filtered stretch stalls the Kafka offset / leaks the Redis PEL.

Implementations

impl<T: CommitToken> RecvBatch<T>

pub fn empty() -> Self

An empty batch (no messages, no DLQ entries).

pub fn from_messages(messages: Vec<Message<T>>) -> Self

A batch of messages with no DLQ entries (e.g. filters disabled).

pub fn is_empty(&self) -> bool

Whether the batch has no messages AND no filtered-only acks to commit. (DLQ entries may still be present alongside passing messages.)

pub fn len(&self) -> usize

Number of passing messages.

Trait Implementations

impl<T: Debug + CommitToken> Debug for RecvBatch<T>

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

Formats the value using the given formatter.

impl<T: CommitToken> From<RecvBatch<T>> for WorkBatch<T>

fn from(batch: RecvBatch<T>) -> Self

Collapse a RecvBatch into a WorkBatch.

Each Message<T> becomes a Record; its token is collected into commit_tokens (preserving order); dlq_entries carry straight across. filtered_tokens (acks of records removed by inbound drop/dlq filters) are appended to commit_tokens so the block commit advances the source past them – the commit-token count is deliberately NOT tied to records.len(). Payloads are already Bytes – each is a move.