Struct ReplaceReducer 

pub struct ReplaceReducer<T> { /* private fields */ }

Available on crate feature graph only.

Built-in reducer: replace with incoming value (last-write-wins).

For any two values, ReplaceReducer always returns the incoming value, discarding the current value. This is the simplest merge strategy and is useful when only the latest value matters.

Example

use adk_graph::functional::{TypedReducer, ReplaceReducer};

let reducer = ReplaceReducer::<String>::new();
let result = reducer.reduce("old".to_string(), "new".to_string());
assert_eq!(result, "new");

Implementations

impl<T> ReplaceReducer<T>

pub fn new() -> ReplaceReducer<T>

Available on crate feature functional only.

Create a new ReplaceReducer.

Trait Implementations

impl<T> Default for ReplaceReducer<T>

fn default() -> ReplaceReducer<T>

Returns the “default value” for a type.

impl<T> Send for ReplaceReducer<T>

impl<T> Sync for ReplaceReducer<T>

impl<T> TypedReducer for ReplaceReducer<T>

where T: Serialize + DeserializeOwned + Send + Sync,

type Value = T

The value type this reducer operates on.

fn reduce(&self, _current: T, incoming: T) -> T

Merge two values. Called when parallel tasks produce outputs for the same state key.