T
- the source value typeR
- the output value typepublic final class OnSubscribeConcatMap<T,R> extends Object implements Observable.OnSubscribe<R>
Modifier and Type | Field and Description |
---|---|
static int |
BOUNDARY
Whenever the main fires an error, wait until the inner terminates.
|
static int |
END
Delay all errors to the very end.
|
static int |
IMMEDIATE
Whenever any Observable fires an error, terminate with that error immediately.
|
Constructor and Description |
---|
OnSubscribeConcatMap(Observable<? extends T> source,
Func1<? super T,? extends Observable<? extends R>> mapper,
int prefetch,
int delayErrorMode) |
public static final int IMMEDIATE
public static final int BOUNDARY
public static final int END
public OnSubscribeConcatMap(Observable<? extends T> source, Func1<? super T,? extends Observable<? extends R>> mapper, int prefetch, int delayErrorMode)
public void call(Subscriber<? super R> child)
call
in interface Action1<Subscriber<? super R>>
Copyright © 2017. All rights reserved.