public final class Aggregate
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
static class |
Aggregate.Projected<V,T,U>
Computes an aggregated value of the source Ts by applying a sum function and applying the divide function when the source
finishes, sending the result to the output.
|
static class |
Aggregate.Scan<T>
Creates an observable which accumultates the given source and submits each intermediate results to its subscribers.
|
static class |
Aggregate.ScanSeeded<U,T>
Creates an observable which accumultates the given source and submits each intermediate results to its subscribers.
|
static class |
Aggregate.Seeded<U,T>
Apply an accumulator function over the observable source and submit the accumulated value to the returned observable.
|
static class |
Aggregate.SeededIndexedProjected<V,T,U>
Computes an aggregated value of the source Ts by applying a
sum function and applying the divide function when the source
finishes, sending the result to the output.
|
static class |
Aggregate.Simple<T>
Apply an accumulator function over the observable source
and submit the accumulated value to the returned observable at each incoming value.
|