Skip to main content

ECB

Type Alias ECB 

Source
type ECB<T> = ConsolidatingContainerBuilder<Vec<(DataflowErrorSer, T, Diff)>>;
Expand description

Container builder used for the err output of every flat_map variant. Pre-refactor the merged Ok/Err stream flowed through a ConsolidatingContainerBuilder before the map_fallible demux split it; we preserve that consolidation here so errors with the same (error, time) cancel within a batch rather than propagating to downstream.

Aliased Typeยง

struct ECB<T> { /* private fields */ }