Struct ClosureReducer 

pub struct ClosureReducer<T, F> { /* private fields */ }

A custom binary Reducer backed by a closure.

Implementations

impl<T, F> ClosureReducer<T, F>

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

pub fn new(f: F) -> Self

Creates a custom reducer from a binary merge closure.

Trait Implementations

impl<T, F> Reducer<T> for ClosureReducer<T, F>

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

fn reduce(&self, current: T, update: T) -> Result<T>

Merges update into current, producing the new channel value.