Struct BinaryOperatorAggregate 

pub struct BinaryOperatorAggregate<T, F>
where
    F: Fn(T, T) -> T + Send + Sync,
{ /* private fields */ }

A channel that reduces values using a binary operator.

This channel maintains a single value and applies a reduction function when new values are written. This is useful for operations like summing, finding max/min, or any other associative binary operation.

Example

use rust_langgraph::channels::{BaseChannel, BinaryOperatorAggregate};

// Sum reducer
let mut channel = BinaryOperatorAggregate::new(0, |a, b| a + b);
channel.update(vec![serde_json::json!(1), serde_json::json!(2), serde_json::json!(3)]).unwrap();
assert_eq!(channel.get().unwrap(), Some(serde_json::json!(6)));

Implementations

impl<T, F> BinaryOperatorAggregate<T, F>

where T: Clone, F: Fn(T, T) -> T + Send + Sync + 'static,

pub fn new(initial: T, reducer: F) -> Self

Create a new BinaryOperatorAggregate with an initial value and reducer

pub fn value(&self) -> &T

Get a reference to the current value

Trait Implementations

impl<T, F> BaseChannel for BinaryOperatorAggregate<T, F>

where T: Serialize + for<'de> Deserialize<'de> + Clone + Send + Sync + Debug + 'static, F: Fn(T, T) -> T + Send + Sync + 'static,

fn get(&self) -> Result<Option<Value>>

Get the current value as JSON

fn update(&mut self, values: Vec<Value>) -> Result<()>

Update the channel with new values

fn checkpoint(&self) -> Result<Value>

Serialize the channel state for checkpointing

fn from_checkpoint(_data: Value) -> Result<Box<dyn BaseChannel>>

Restore the channel state from a checkpoint

fn type_name(&self) -> &'static str

Get the channel’s type name for debugging

fn is_empty(&self) -> bool

Check if the channel is empty

impl<T, F> Debug for BinaryOperatorAggregate<T, F>

where T: Debug, F: Fn(T, T) -> T + Send + Sync,

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

Formats the value using the given formatter.