Struct EmitCollector 

pub struct EmitCollector<T> {
    pub records: Vec<Record<T>>,
    pub rejected: usize,
    /* private fields */
}

An EmitRecord implementation that collects records into a Vec, optionally reporting Flow::Blocked once a capacity is reached (rejected records are counted, not stored) — for testing blocked-path handling.

Fields

records: Vec<Record<T>>

Records accepted so far.

rejected: usize

Records rejected after the block threshold was reached.

Implementations

impl<T> EmitCollector<T>

pub fn new() -> Self

A collector that always accepts.

pub fn blocking_after(n: usize) -> Self

A collector that accepts n records, then rejects with Flow::Blocked.

pub fn payloads(&self) -> Vec<T>

where T: Clone,

The collected payloads, cloned out.

Trait Implementations

impl<T: Debug> Debug for EmitCollector<T>

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

Formats the value using the given formatter.

impl<T: Default> Default for EmitCollector<T>

fn default() -> EmitCollector<T>

Returns the “default value” for a type.

impl<'buf, T> EmitRecord<'buf, T> for EmitCollector<T>

fn emit(&mut self, rec: Record<T>) -> Flow

Hand one record to the chain. A Flow::Blocked return means downstream is full; the deserializer stops emitting and the driver retries the batch from the current payload cursor.