Struct CustomReducer 

pub struct CustomReducer<F>
where
    F: Fn(Option<&Value>, &Value) -> Result<Value, AgentError> + Send + Sync,
{ /* private fields */ }

Custom reducer using a closure

Allows defining custom merge logic with a function.

Implementations

impl<F> CustomReducer<F>

where F: Fn(Option<&Value>, &Value) -> Result<Value, AgentError> + Send + Sync,

pub fn new(name: impl Into<String>, func: F) -> CustomReducer<F>

Create a new custom reducer

Trait Implementations

impl<F> Reducer for CustomReducer<F>

where F: Fn(Option<&Value>, &Value) -> Result<Value, AgentError> + Send + Sync,

fn reduce<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, current: Option<&'life1 Value>, update: &'life2 Value, ) -> Pin<Box<dyn Future<Output = Result<Value, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, CustomReducer<F>: 'async_trait,

Reduce the current value with the update value

fn name(&self) -> &str

Returns the name of this reducer

fn reducer_type(&self) -> ReducerType

Returns the type of this reducer