Aggregates

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

If you are interested in perform in a whole collection, consider combine with Last() operator if needed.

Count

Count the items recieved.

Count()

Sum

Sum the items recieved.

Sum()

Min

Minimium of the items recieved.

Min()

Max

Maximum of the items recieved.

Max()

Average

Average of the items recieved.

Average()

Any

Return true if any of the recieved items satisfy a condition.

Any(ReactiveCondition<T> condition)

All

Return true if all of the recieved items satisfy a condition.

All(ReactiveCondition<T> condition)

None

Return true if none of the recieved items satisfy a condition.

None(ReactiveCondition<T> condition)