T - the source and result element typeU - the window's own type (ignored)public static class Buffer.WithBoundary<T,U> extends java.lang.Object implements Observable<java.util.List<T>>
Exception semantics: if any Observable throws an error, the whole process terminates with error.
| Modifier and Type | Field and Description |
|---|---|
protected Observable<U> |
boundary
The buffer closing selector for each registerer.
|
protected Observable<? extends T> |
source
The source observable.
|
| Constructor and Description |
|---|
WithBoundary(Observable<? extends T> source,
Observable<U> boundary)
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 Observable<U> boundary
public WithBoundary(@Nonnull
Observable<? extends T> source,
@Nonnull
Observable<U> boundary)
source - the source sequenceboundary - the notification source of the boundary@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