Aggregate<TSource> sealed class Aggregate<TSource> : Producer<TSource, _<TSource>> Documentation Code public Aggregate(IObservable<TSource> source, Func<TSource, TSource, TSource> accumulator)