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,
Helper to create a BinaryOperatorAggregate channel