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