hu.akarnokd.reactive4java.reactive

Class Resume.OnError<T>

java.lang.Object

hu.akarnokd.reactive4java.reactive.Resume.OnError<T>

Type Parameters:

T - the type of the values

All Implemented Interfaces:

Observable<T>

Enclosing class:

Resume

public static final class Resume.OnError<T>
extends java.lang.Object
implements Observable<T>

It tries to submit the values of first observable, but when it throws an exeption, the next observable within source is used further on. Basically a failover between the Observables. If the current source finish() then the result observable calls finish(). If the last of the sources calls error() the result observable calls error()

Field Summary

Fields

Modifier and Type	Field and Description
java.lang.Iterable<? extends Observable<? extends T>>	sources The source sequence.

Constructor Summary

Constructors

Constructor and Description
OnError(java.lang.Iterable<? extends Observable<? extends T>> sources) 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

sources

public final java.lang.Iterable<? extends Observable<? extends T>> sources

The source sequence.

Constructor Detail

OnError

public OnError(java.lang.Iterable<? extends Observable<? extends T>> sources)

Constructor.

Parameters:

sources - the source sequences

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