Struct ContributingNodeAdapter 

pub struct ContributingNodeAdapter<S>
where
    S: StateMerge + Clone + Send + Sync + 'static,
{ /* private fields */ }

Runnable<S, S> adapter that snapshots the inbound state, runs an inner Runnable<S, S::Contribution> to produce only the slots the node touched, and folds that contribution into the snapshot via S::merge_contribution.

Implementations

impl<S> ContributingNodeAdapter<S>

where S: StateMerge + Clone + Send + Sync + 'static,

pub fn new<R>(inner: R) -> Self

where R: Runnable<S, S::Contribution> + 'static,

Wrap inner. The inner runnable’s output is S::Contribution — typically built via S::Contribution::default().with_<field>(…) chained per slot the node intends to write.

Trait Implementations

impl<S> Debug for ContributingNodeAdapter<S>

where S: StateMerge + Clone + Send + Sync + 'static,

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

Formats the value using the given formatter.

impl<S> Runnable<S, S> for ContributingNodeAdapter<S>

where S: StateMerge + Clone + Send + Sync + 'static,

fn invoke<'life0, 'life1, 'async_trait>( &'life0 self, input: S, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<S>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Single-shot invocation.

fn batch<'life0, 'life1, 'async_trait>( &'life0 self, inputs: Vec<I>, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<O>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Batch invocation. The default runs invoke sequentially over the input vector. Implementors that can parallelize (e.g. independent provider calls) override this.

fn stream<'life0, 'life1, 'async_trait>( &'life0 self, input: I, mode: StreamMode, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<StreamChunk<O>, Error>> + Send + 'life0>>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Streaming invocation, shaped by mode (see StreamMode).

fn name(&self) -> Cow<'_, str>

Human-readable identifier used by tracing and debug output. Default is the Rust type name — implementors may override with a domain label (e.g. "anthropic-messages", "json-parser").