Package rx.internal.operators
Class OnSubscribeConcatMap<T,R>
java.lang.Object
rx.internal.operators.OnSubscribeConcatMap<T,R>
- Type Parameters:
T
- the source value typeR
- the output value type
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super R>>
,Function
,Observable.OnSubscribe<R>
Maps a source sequence into Observables and concatenates them in order, subscribing
to one at a time.
- Since:
- 1.1.2
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final int
Whenever the main fires an error, wait until the inner terminates.(package private) final int
How to handle errors from the main and inner Observables.static final int
Delay all errors to the very end.static final int
Whenever any Observable fires an error, terminate with that error immediately.(package private) final Func1
<? super T, ? extends Observable<? extends R>> (package private) final int
(package private) final Observable
<? extends T> -
Constructor Summary
ConstructorsConstructorDescriptionOnSubscribeConcatMap
(Observable<? extends T> source, Func1<? super T, ? extends Observable<? extends R>> mapper, int prefetch, int delayErrorMode) -
Method Summary
-
Field Details
-
source
-
mapper
-
prefetch
final int prefetch -
delayErrorMode
final int delayErrorModeHow to handle errors from the main and inner Observables. See the constants below. -
IMMEDIATE
public static final int IMMEDIATEWhenever any Observable fires an error, terminate with that error immediately.- See Also:
-
BOUNDARY
public static final int BOUNDARYWhenever the main fires an error, wait until the inner terminates.- See Also:
-
END
public static final int ENDDelay all errors to the very end.- See Also:
-
-
Constructor Details
-
OnSubscribeConcatMap
public OnSubscribeConcatMap(Observable<? extends T> source, Func1<? super T, ? extends Observable<? extends R>> mapper, int prefetch, int delayErrorMode)
-
-
Method Details