Package rx.internal.operators
Class OnSubscribeFlattenIterable<T,R>
java.lang.Object
rx.internal.operators.OnSubscribeFlattenIterable<T,R>
- Type Parameters:
T
- the input value typeR
- the output value type
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super R>>
,Function
,Observable.OnSubscribe<R>
public final class OnSubscribeFlattenIterable<T,R>
extends Object
implements Observable.OnSubscribe<R>
Flattens a sequence if Iterable sources, generated via a function, into a single sequence.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
(package private) static final class
A custom flattener that works from a scalar value and computes the iterable during subscription time. -
Field Summary
Fields -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
OnSubscribeFlattenIterable
(Observable<? extends T> source, Func1<? super T, ? extends Iterable<? extends R>> mapper, int prefetch) Protected: use createFrom to handle source-dependent optimizations. -
Method Summary
Modifier and TypeMethodDescriptionvoid
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)
-
Field Details
-
source
-
mapper
-
prefetch
final int prefetch
-
-
Constructor Details
-
Method Details
-
call
-
createFrom
public static <T,R> Observable<R> createFrom(Observable<? extends T> source, Func1<? super T, ? extends Iterable<? extends R>> mapper, int prefetch)
-