T - the source and result element typeU - the window's own type (ignored)public static class Buffer.WithClosing<T,U> extends java.lang.Object implements Observable<java.util.List<T>>
| Modifier and Type | Field and Description |
|---|---|
protected Func0<? extends Observable<U>> |
bufferClosingSelector
The buffer closing selector for each registerer.
|
protected Observable<? extends T> |
source
The source observable.
|
| Constructor and Description |
|---|
WithClosing(Observable<? extends T> source,
Func0<? extends Observable<U>> bufferClosingSelector)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
java.io.Closeable |
register(Observer<? super java.util.List<T>> observer)
Registers an observer for the notification of Ts.
|
@Nonnull protected final Observable<? extends T> source
@Nonnull protected final Func0<? extends Observable<U>> bufferClosingSelector
public WithClosing(@Nonnull
Observable<? extends T> source,
@Nonnull
Func0<? extends Observable<U>> bufferClosingSelector)
source - the source sequencebufferClosingSelector - the window selector@Nonnull
public java.io.Closeable register(@Nonnull
Observer<? super java.util.List<T>> observer)
Observableregister in interface Observable<java.util.List<T>>observer - the observer of Ts or any supertype of it