hu.akarnokd.reactive4java.reactive

Class Concat.FromObservable.IndexedSelector<T,U>

java.lang.Object

hu.akarnokd.reactive4java.reactive.Concat.FromObservable.IndexedSelector<T,U>

Type Parameters:

T - the source observable element type

U - the result observable element type

All Implemented Interfaces:

Observable<U>

Enclosing class:

Concat.FromObservable

public static class Concat.FromObservable.IndexedSelector<T,U>
extends java.lang.Object
implements Observable<U>

Concatenate the the multiple sources selected by the indexed function after another.

Exception semantics: if the sources or any inner observer signals an error, the outer observable will signal that error and the sequence is terminated.

Field Summary

Fields

Modifier and Type	Field and Description
protected Func2<? super Observable<? extends T>,? super java.lang.Integer,? extends Observable<? extends U>>	resultSelector The result selector.
protected Observable<? extends Observable<? extends T>>	sources The source.

Constructor Summary

Constructors

Constructor and Description
IndexedSelector(Observable<? extends Observable<? extends T>> sources, Func2<? super Observable<? extends T>,? super java.lang.Integer,? extends Observable<? extends U>> resultSelector) Constructor.

Method Summary

Modifier and Type	Method and Description
java.io.Closeable	register(Observer<? super U> 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

@Nonnull
protected final Observable<? extends Observable<? extends T>> sources

The source.

resultSelector

@Nonnull
protected final Func2<? super Observable<? extends T>,? super java.lang.Integer,? extends Observable<? extends U>> resultSelector

The result selector.

Constructor Detail

IndexedSelector

public IndexedSelector(Observable<? extends Observable<? extends T>> sources,
                       Func2<? super Observable<? extends T>,? super java.lang.Integer,? extends Observable<? extends U>> resultSelector)

Constructor.

Parameters:

sources - the sources

resultSelector - the indexed concatenation result selector

Method Detail

register

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

Description copied from interface: Observable

Registers an observer for the notification of Ts.

Specified by:

register in interface Observable<U>

Parameters:

observer - the observer of Ts or any supertype of it

Returns:

the way of deregister the observer from this provider