Aggregates

Aggregates operators are Hot observers, they emit as soon as a new item is received.

If you want to apply to the whole sequence, consider combine with Last() operator.

Aggregate Count

Count the items received

Count()

Aggregate Sum

Sum the items received

Sum()

Aggregate Min

Minimium of the items received

Min()

Aggregate Max

Maximum of the items received

Max()

Aggregate Average

Average of the items received

Average()

Aggregate Any

Return true if any of the received items satisfy a condition

Any(ReactiveCondition<T> condition)

Aggregate All

Return true if all of the received items satisfy a condition

All(ReactiveCondition<T> condition)

Aggregate None

Return true if none of the received items satisfy a condition

None(ReactiveCondition<T> condition)