Class OnSubscribeFlattenIterable<T,R>

java.lang.Object
rx.internal.operators.OnSubscribeFlattenIterable<T,R>
Type Parameters:
T - the input value type
R - 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.
  • Field Details

    • source

      final Observable<? extends T> source
    • mapper

      final Func1<? super T,? extends Iterable<? extends R>> mapper
    • prefetch

      final int prefetch
  • Constructor Details

    • OnSubscribeFlattenIterable

      protected OnSubscribeFlattenIterable(Observable<? extends T> source, Func1<? super T,? extends Iterable<? extends R>> mapper, int prefetch)
      Protected: use createFrom to handle source-dependent optimizations.
  • Method Details