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>
public final class OnSubscribeConcatMap<T,R> extends java.lang.Object implements 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 Classes Modifier and Type Class Description (package private) static class
OnSubscribeConcatMap.ConcatMapInnerScalarProducer<T,R>
(package private) static class
OnSubscribeConcatMap.ConcatMapInnerSubscriber<T,R>
(package private) static class
OnSubscribeConcatMap.ConcatMapSubscriber<T,R>
-
Field Summary
Fields Modifier and Type Field Description static int
BOUNDARY
Whenever the main fires an error, wait until the inner terminates.(package private) int
delayErrorMode
How to handle errors from the main and inner Observables.static int
END
Delay all errors to the very end.static int
IMMEDIATE
Whenever any Observable fires an error, terminate with that error immediately.(package private) Func1<? super T,? extends Observable<? extends R>>
mapper
(package private) int
prefetch
(package private) Observable<? extends T>
source
-
Constructor Summary
Constructors Constructor Description OnSubscribeConcatMap(Observable<? extends T> source, Func1<? super T,? extends Observable<? extends R>> mapper, int prefetch, int delayErrorMode)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
call(Subscriber<? super R> child)
-
-
-
Field Detail
-
source
final Observable<? extends T> source
-
mapper
final Func1<? super T,? extends Observable<? extends R>> mapper
-
prefetch
final int prefetch
-
delayErrorMode
final int delayErrorMode
How to handle errors from the main and inner Observables. See the constants below.
-
IMMEDIATE
public static final int IMMEDIATE
Whenever any Observable fires an error, terminate with that error immediately.- See Also:
- Constant Field Values
-
BOUNDARY
public static final int BOUNDARY
Whenever the main fires an error, wait until the inner terminates.- See Also:
- Constant Field Values
-
END
public static final int END
Delay all errors to the very end.- See Also:
- Constant Field Values
-
-
Constructor Detail
-
OnSubscribeConcatMap
public OnSubscribeConcatMap(Observable<? extends T> source, Func1<? super T,? extends Observable<? extends R>> mapper, int prefetch, int delayErrorMode)
-
-
Method Detail
-
call
public void call(Subscriber<? super R> child)
-
-