hu.akarnokd.reactive4java.reactive

Class Delay.ByObservable<T,U,V>

java.lang.Object

hu.akarnokd.reactive4java.util.Producer<T>

hu.akarnokd.reactive4java.reactive.Delay.ByObservable<T,U,V>

Type Parameters:

T - the source and output element type

All Implemented Interfaces:

Observable<T>

Enclosing class:

Delay

public static class Delay.ByObservable<T,U,V>
extends Producer<T>

Delays the observable sequence based on the subscription delay and per element delay provided by a function.

Both registerDelay and delaySelector observables trigger the registration/delivery of the original value by next or finish calls.

Nested Class Summary

Nested classes/interfaces inherited from class hu.akarnokd.reactive4java.util.Producer

Producer.State<U>

Constructor Summary

Constructors

Constructor and Description
ByObservable(Observable<? extends T> source, Observable<U> registerDelay, Func1<? super T,? extends Observable<V>> delaySelector) Constructor.

Method Summary

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.

Methods inherited from class hu.akarnokd.reactive4java.util.Producer

register, registerRaw

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ByObservable

public ByObservable(@Nonnull
                    Observable<? extends T> source,
                    @Nullable
                    Observable<U> registerDelay,
                    @Nonnull
                    Func1<? super T,? extends Observable<V>> delaySelector)

Constructor.

Parameters:

source - the source sequence.

registerDelay - the optional registration delay

delaySelector - the delay selector for each value.

Method Detail

run

protected java.io.Closeable run(Observer<? super T> observer,
                                java.io.Closeable cancel,
                                Action1<java.io.Closeable> setSink)

Description copied from class: Producer

The core implementation of the operator, called upon registration to the producer.

Note that the observer is not automatically detached in case of error or finish cases. Implementations should ensure proper termination.

Specified by:

run in class Producer<T>

Parameters:

observer - the observer to send notifications on

cancel - the cancellation handler from the run() call, allows self cancellations

setSink - communicates the sink to the registering party which allows consumers to tunnel close calls into the sink, which can stop processing

Returns:

the closeable representing all resources and/or registrations to cancel at once.