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 number of items recieved

Count()

Aggregate CountDown

Countdown the number of items recieved, and call a callback function when arrive 0

Count()

Aggregate Sum

Emits items recieved sum

Sum()

Aggregate Min

Emits the minimum-valued item

Min()

Aggregate Max

Emits the maximum-valued item

Max()

Aggregate Average

Emits the average of recieved items

Average()

Aggregate RMS

Emits the root mean square of recieved items

Average()

Aggregate Any

Emits true if any of the received items satisfy a condition

Any(ReactiveCondition<T> condition)

Aggregate All

Emits true if all of the received items satisfy a condition

All(ReactiveCondition<T> condition)

Aggregate None

Emits true if none of the received items satisfy a condition

None(ReactiveCondition<T> condition)