T
- the input value typeR
- the output value typepublic final class OnSubscribeFlattenIterable<T,R> extends Object implements Observable.OnSubscribe<R>
Modifier | Constructor and Description |
---|---|
protected |
OnSubscribeFlattenIterable(Observable<? extends T> source,
Func1<? super T,? extends Iterable<? extends R>> mapper,
int prefetch)
Protected: use createFrom to handle source-dependent optimizations.
|
Modifier and Type | Method and Description |
---|---|
void |
call(Subscriber<? super R> t) |
static <T,R> Observable<R> |
createFrom(Observable<? extends T> source,
Func1<? super T,? extends Iterable<? extends R>> mapper,
int prefetch) |
public void call(Subscriber<? super R> t)
call
in interface Action1<Subscriber<? super R>>
public static <T,R> Observable<R> createFrom(Observable<? extends T> source, Func1<? super T,? extends Iterable<? extends R>> mapper, int prefetch)
Copyright © 2018. All rights reserved.