Struct PendingBatch 

pub struct PendingBatch<T> {
    items: Vec<T>,
    total_rows: usize,
    first_submitted_at: Option<Instant>,
}

Accumulates complete submissions in arrival order, without interpreting their data.

Fields

items: Vec<T>

total_rows: usize

first_submitted_at: Option<Instant>

Implementations

impl<T> PendingBatch<T>

pub fn new() -> Self

Creates an empty batch.

pub fn push(&mut self, item: T, total_rows: usize, now: Instant)

Appends a complete submission without moving the first submission’s timestamp.

pub fn total_rows(&self) -> usize

Returns the accumulated row count, saturated at usize::MAX.

pub fn len(&self) -> usize

Returns the number of complete submissions.

pub fn is_empty(&self) -> bool

Returns whether there are no submissions, including zero-row submissions.

pub fn first_submitted_at(&self) -> Option<Instant>

Returns the time the first submission was appended to the current batch.

pub fn take(&mut self) -> Vec<T>

Takes all submissions in arrival order and resets the batch’s accounting.

Trait Implementations

impl<T: Debug> Debug for PendingBatch<T>

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

Formats the value using the given formatter.

impl<T> Default for PendingBatch<T>

fn default() -> Self

Returns the “default value” for a type.