Struct multistream_batch::channel::tx_buf_batch::Complete

pub struct Complete<'i, I: Debug>(_);

Provides actions that can be taken to consume complete batch.

Implementations

impl<'i, I: Debug> Complete<'i, I>

pub fn retry(&mut self)

Restarts the batch. TxBufBatchChannel.next() will iterate already received items starting from oldest one in the current batch.

pub fn commit(&mut self)

Commits the current batch by dropping all buffered items.

pub fn drain(&mut self) -> Drain<'_, I>

Commits the current batch by draining all buffered items.

Trait Implementations

impl<'i, I: Debug> Debug for Complete<'i, I>

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

Formats the value using the given formatter.