T - the source and result element typeU - the window boundary element type (irrelevantpublic static class Windowing.WithBoundary<T,U> extends java.lang.Object implements Observable<Observable<T>>
The first window opens immediately, The current window is closed when the boundary observable sequence has sent a value. The finish of the boundary will finish both inner and outer observables.
Exception semantics: exception thrown by the source or the windowClosingSelector's observable is propagated to both the outer and inner observable returned.
| Modifier and Type | Field and Description |
|---|---|
protected Observable<U> |
boundary
The boundary sequence.
|
protected Observable<? extends T> |
source
The soruce sequence.
|
| Constructor and Description |
|---|
WithBoundary(Observable<? extends T> source,
Observable<U> boundary)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
java.io.Closeable |
register(Observer<? super Observable<T>> observer)
Registers an observer for the notification of Ts.
|
protected Observable<? extends T> source
protected Observable<U> boundary
public WithBoundary(@Nonnull
Observable<? extends T> source,
@Nonnull
Observable<U> boundary)
source - the source sequenceboundary - the window boundary indicator.@Nonnull
public java.io.Closeable register(@Nonnull
Observer<? super Observable<T>> observer)
Observableregister in interface Observable<Observable<T>>observer - the observer of Ts or any supertype of it