T - the element type of the sourceU - the element type of the signaller, irrelevantpublic static final class Skip.Until<T,U> extends java.lang.Object implements Observable<T>
Once the signaller sends its first value, it gets deregistered.
Exception semantics: exceptions thrown by source or singaller is immediately forwarded to the output and the stream is terminated.
| Constructor and Description |
|---|
Until(Observable<? extends T> source,
Observable<U> signaller)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
java.io.Closeable |
register(Observer<? super T> observer)
Registers an observer for the notification of Ts.
|
public Until(Observable<? extends T> source, Observable<U> signaller)
source - the source of Tssignaller - the source of Us@Nonnull
public java.io.Closeable register(@Nonnull
Observer<? super T> observer)
Observableregister in interface Observable<T>observer - the observer of Ts or any supertype of it