hu.akarnokd.reactive4java.reactive

Class Timeout.Switch<T>

java.lang.Object

hu.akarnokd.reactive4java.reactive.Timeout.Switch<T>

Type Parameters:

T - the element tye

All Implemented Interfaces:

Observable<T>

Enclosing class:

Timeout

public static class Timeout.Switch<T>
extends java.lang.Object
implements Observable<T>

Applies a timeout for each element in the source sequence. If an element times out, the source sequence is switched to the other source.

Field Summary

Fields

Modifier and Type	Field and Description
protected Observable<? extends T>	other
protected Scheduler	pool
protected Observable<? extends T>	source
protected long	time
protected java.util.concurrent.TimeUnit	unit

Constructor Summary

Constructors

Constructor and Description
Switch(Observable<? extends T> source, long time, java.util.concurrent.TimeUnit unit, Observable<? extends T> other, Scheduler pool) 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

Field Detail

source

protected final Observable<? extends T> source

time

protected final long time

unit

protected final java.util.concurrent.TimeUnit unit

pool

protected final Scheduler pool

other

protected final Observable<? extends T> other

Constructor Detail

Switch

public Switch(Observable<? extends T> source,
              long time,
              java.util.concurrent.TimeUnit unit,
              Observable<? extends T> other,
              Scheduler pool)

Constructor.

Parameters:

source - the source sequence

time - the timeout for each element

unit - the tim unit

other - the other stream to switch to in case of timeout

pool - the scheduler for the timed operations

Method Detail

register

@Nonnull
public java.io.Closeable register(@Nonnull
                                            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