hu.akarnokd.reactive4java.reactive

Class Timeout.ByObservables<T,U,V>

java.lang.Object

hu.akarnokd.reactive4java.reactive.Timeout.ByObservables<T,U,V>

Type Parameters:

T - the source and result element type

U - the initial timeout element type, irrelevant

V - the per-element timeout type, irrelevant

All Implemented Interfaces:

Observable<T>

Enclosing class:

Timeout

public static class Timeout.ByObservables<T,U,V>
extends java.lang.Object
implements Observable<T>

Applies a timeout to each element in the source sequence, starting with the timeout from the firsTimeout observabe, then, for each element a separate window is opened in the form of observable sequence. If any of these window observables fire next or finish, the sequence is switched to the other observable.

Constructor Summary

Constructors

Constructor and Description
ByObservables(Observable<? extends T> source, Observable<U> firstTimeout, Func1<? super T,? extends Observable<V>> timeoutSelector, Observable<? extends T> other) Constructor.

Method Summary

Modifier and Type	Method and Description
java.io.Closeable	register(Observer<? super T> observer) Registers an observer for the notification of Ts.

Methods inherited from class java.lang.Object

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

Constructor Detail

ByObservables

public ByObservables(Observable<? extends T> source,
                     Observable<U> firstTimeout,
                     Func1<? super T,? extends Observable<V>> timeoutSelector,
                     Observable<? extends T> other)

Constructor.

Parameters:

source - the source sequence

firstTimeout - the timeout observable

timeoutSelector - the selector for timeouts for each element

other - the other source to switch to

Method Detail

register

@Nonnull
public java.io.Closeable register(Observer<? super T> observer)

Description copied from interface: Observable

Registers an observer for the notification of Ts.

Specified by:

register in interface Observable<T>

Parameters:

observer - the observer of Ts or any supertype of it

Returns:

the way of deregister the observer from this provider