Trait EmitRecord 

pub trait EmitRecord<'buf, T> {
    // Required method
    fn emit(&mut self, rec: Record<T>) -> Flow;
}

Push-style receiver for deserialized records (0..N per payload).

Required Methods

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.

Implementors