Struct JoinBuilder 

pub struct JoinBuilder<O, R: Spawn + 'static> { /* private fields */ }

Type-erased input descriptor for joins.

Each input captures a subscribe-and-forward function that, given the AimDb handle, subscribes to the input buffer and forwards typed values as JoinTrigger into a shared mpsc::UnboundedSender.

Configures a multi-input join transform.

Created by RecordRegistrar::transform_join_raw(). Add inputs with .input(), then set state and handler with .with_state().on_trigger().

Implementations

impl<O, R> JoinBuilder<O, R>

where O: Send + Sync + Clone + Debug + 'static, R: Spawn + 'static,

pub fn input<I>(self, key: impl RecordKey) -> Self

where I: Send + Sync + Clone + Debug + 'static,

Add a typed input to the join.

The input index corresponds to the order of .input() calls, starting from 0.

pub fn with_state<S: Send + Sync + 'static>( self, initial: S, ) -> JoinStateBuilder<O, S, R>

Set the join state and begin configuring the trigger handler.