Class 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 java.lang.Object
    implements Observable.OnSubscribe<R>
    Flattens a sequence if Iterable sources, generated via a function, into a single sequence.
    • Field Detail

      • mapper

        final Func1<? super T,​? extends java.lang.Iterable<? extends R>> mapper
      • prefetch

        final int prefetch
    • Constructor Detail

      • OnSubscribeFlattenIterable

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

      • createFrom

        public static <T,​R> Observable<R> createFrom​(Observable<? extends T> source,
                                                           Func1<? super T,​? extends java.lang.Iterable<? extends R>> mapper,
                                                           int prefetch)