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)