Struct SplitBuilder 

pub struct SplitBuilder<DF: RecFamily, CurF: RecFamily, D, P> { /* private fields */ }

Accumulates split-sink branches before the routing closure is supplied. Built by ChainBuilder::split; each add declares one destination and hands back a typed handle, then route takes the closure that dispatches to them.

Implementations

impl<DF: RecFamily, CurF: RecFamily, D, P> SplitBuilder<DF, CurF, D, P>

pub fn add<F, E, R>(&mut self, encoder: E, router: R, sink: SinkCtx) -> Sink<F>

where F: RecFamily + 'static, E: RowEncoder<F> + Clone + Send + 'static, R: RecordRouter<F> + 'static,

Declare one destination branch of family F and return its typed, Copy Sink<F> handle. sink comes from ChainCtx::sink; encoder/router are that table’s, exactly as for ChainBuilder::sink. The declaration order fixes the handle indices; call once per destination, then route.

pub fn route<G>(self, route: G) -> RoutedSplit<DF, CurF, D, P, G>

where G: for<'buf> FnMut(CurF::Rec<'buf>, &mut SplitEmitter<'_>) + Send + 'static,

Supply the routing closure (classify + extract per record in one match) and finish the split. The closure emits each record to exactly one branch via SplitEmitter::emit; emitting to none invokes the unmatched policy from ChainBuilder::split.

Trait Implementations

impl<DF: RecFamily, CurF: RecFamily, D, P> Debug for SplitBuilder<DF, CurF, D, P>

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

Formats the value using the given formatter.