T
- the upstream value typepublic final class OnSubscribeFlatMapCompletable<T> extends Object implements Observable.OnSubscribe<T>
History: 1.2.7 - experimental
Constructor and Description |
---|
OnSubscribeFlatMapCompletable(Observable<T> source,
Func1<? super T,? extends Completable> mapper,
boolean delayErrors,
int maxConcurrency) |
public OnSubscribeFlatMapCompletable(Observable<T> source, Func1<? super T,? extends Completable> mapper, boolean delayErrors, int maxConcurrency)
public void call(Subscriber<? super T> child)
call
in interface Action1<Subscriber<? super T>>
Copyright © 2018. All rights reserved.