Struct Batch 

pub struct Batch {
    held: Vec<SeatUpdate>,
    opened: Option<Instant>,
    quiet: Option<Instant>,
}

The updates waiting for one write, and when they have waited long enough.

Fields

held: Vec<SeatUpdate>

opened: Option<Instant>

When the first held update landed, which the ceiling counts from.

quiet: Option<Instant>

When the window the last arrival opened closes.

Implementations

impl Batch

pub fn push(&mut self, at: Instant, frame: SeatUpdate)

Hold one update, and hold the window open from its arrival.

The frame carries the number its seat minted, so what the client reads off the wire says which frames of the seat’s stream this write stands for.

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

When the held updates go out: the window the last arrival opened, unless the ceiling is nearer.

None with nothing held, which is what keeps a caller from waiting on a timer it has no reason to arm.

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

Take what is held, leaving the batch empty.

Trait Implementations

impl Default for Batch

fn default() -> Self

Returns the “default value” for a type.