T - the source and output element typepublic static class Delay.ByObservable<T,U,V> extends Producer<T>
Both registerDelay and delaySelector observables trigger the registration/delivery of the original value by next or finish calls.
Producer.State<U>| Constructor and Description |
|---|
ByObservable(Observable<? extends T> source,
Observable<U> registerDelay,
Func1<? super T,? extends Observable<V>> delaySelector)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
protected java.io.Closeable |
run(Observer<? super T> observer,
java.io.Closeable cancel,
Action1<java.io.Closeable> setSink)
The core implementation of the operator, called upon
registration to the producer.
|
register, registerRawpublic ByObservable(@Nonnull
Observable<? extends T> source,
@Nullable
Observable<U> registerDelay,
@Nonnull
Func1<? super T,? extends Observable<V>> delaySelector)
source - the source sequence.registerDelay - the optional registration delaydelaySelector - the delay selector for each value.protected java.io.Closeable run(Observer<? super T> observer, java.io.Closeable cancel, Action1<java.io.Closeable> setSink)
ProducerNote that the observer is not automatically detached in case of error or finish cases. Implementations should ensure proper termination.
run in class Producer<T>observer - the observer to send notifications oncancel - the cancellation handler from the run() call, allows self cancellationssetSink - communicates the sink to the registering party which allows consumers
to tunnel close calls into the sink, which can stop processing