T - the input element typeU - the output element typepublic static final class Aggregate.Seeded<U,T> extends java.lang.Object implements Observable<U>
| Constructor and Description |
|---|
Seeded(Observable<? extends T> source,
U seed,
Func2<? super U,? super T,? extends U> accumulator)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
java.io.Closeable |
register(Observer<? super U> observer)
Registers an observer for the notification of Ts.
|
public Seeded(Observable<? extends T> source, U seed, Func2<? super U,? super T,? extends U> accumulator)
source - the source observableseed - the initial value of the accumulatoraccumulator - the accumulator function where the first parameter is the current accumulated value and the second is the now received value.@Nonnull
public java.io.Closeable register(@Nonnull
Observer<? super U> observer)
Observableregister in interface Observable<U>observer - the observer of Ts or any supertype of it