Struct FlatMap 

pub struct FlatMap<OutF, G, N>
where
    OutF: RecFamily,
{ /* private fields */ }

flat_map: one record in, 0..N out via a stack-borrowed Emitter. Carries the output family as a type parameter so the impl is fully constrained (closure argument types are not associated bindings).

Trait Implementations

impl<OutF, G, N> Clone for FlatMap<OutF, G, N>

where OutF: Clone + RecFamily, G: Clone, N: Clone,

fn clone(&self) -> FlatMap<OutF, G, N>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<In, OutF, G, N> Collector<In> for FlatMap<OutF, G, N>

where OutF: RecFamily, G: FnMut(In, &mut Emitter<'_, OutF>), N: for<'buf> Collector<<OutF as RecFamily>::Rec<'buf>>,

fn push(&mut self, rec: Record<In>) -> Flow

Push one record. Flow::Blocked propagates up to the boundary.

impl<OutF, G, N> Debug for FlatMap<OutF, G, N>

where OutF: Debug + RecFamily, G: Debug, N: Debug,

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

Formats the value using the given formatter.

impl<OutF, G, N> StageLifecycle for FlatMap<OutF, G, N>

where OutF: RecFamily, N: StageLifecycle,

fn on_batch_end(&mut self, elapsed: Duration)

Flush per-batch metric accumulators. elapsed is the chain-level batch duration: per-stage attribution inside one inlined loop is not measurable without per-record clocks, so every stage reports the chain figure, keeping the histograms comparable.

fn take_fatal(&mut self) -> Option<FatalError>

Take the first fatal error recorded by any stage.

fn relieve(&mut self) -> Flow

Let the terminal stage drain parked output. Flow::Blocked means it is still backed up and the chain must not accept new payloads.

fn flush_terminal(&mut self) -> Flow

Seal and hand off all terminal buffers, partial chunks included. Flow::Blocked means not everything could be sent; retry later.