Struct ChannelReceiver 

pub struct ChannelReceiver { /* private fields */ }

Receiver for channel events.

Implementations

impl ChannelReceiver

pub fn ack_mode(&self) -> AckMode

Get the current ack mode for this receiver.

pub fn current_offset(&self) -> u64

Get the next offset that will be assigned (i.e., total messages received so far).

pub async fn recv(&mut self) -> Result<Event, ChannelError>

Receive the next event.

When AckMode::Auto, messages are automatically acknowledged on receive. When AckMode::Manual, messages are tracked as unacknowledged and must be explicitly acknowledged via [ack]. When AckMode::None, no tracking is performed.

pub fn try_recv(&mut self) -> Result<Option<Event>, ChannelError>

Try to receive an event without blocking.

pub fn ack(&self, offset: u64) -> Result<(), ChannelError>

Acknowledge a message by its offset.

Only meaningful when AckMode::Manual. Removes the message from the unacknowledged set. Returns an error if the offset is not found.

pub fn unacked_count(&self) -> usize

Get the number of unacknowledged messages.

pub fn acked_count(&self) -> usize

Get the number of acknowledged messages.

pub fn get_unacked_messages(&self) -> Vec<(u64, Event)>

Get all unacknowledged messages for re-delivery.

Returns a vector of (offset, event) pairs for messages that have been received but not yet acknowledged.