Skip to main content

binop

Function binop 

Source
pub fn binop<T, F>(initial: T, reducer: F) -> BinaryOperatorAggregate<T, F>
where T: Serialize + for<'de> Deserialize<'de> + Clone + Send + Sync + Debug + 'static, F: Fn(T, T) -> T + Send + Sync + 'static,
Expand description

Helper to create a BinaryOperatorAggregate channel