Class OnSubscribeConcatMap<T,​R>

  • Type Parameters:
    T - the source value type
    R - the output value type
    All Implemented Interfaces:
    Action, Action1<Subscriber<? super R>>, Function, Observable.OnSubscribe<R>

    public final class OnSubscribeConcatMap<T,​R>
    extends java.lang.Object
    implements Observable.OnSubscribe<R>
    Maps a source sequence into Observables and concatenates them in order, subscribing to one at a time.
    Since:
    1.1.2
    • Field Detail

      • prefetch

        final int prefetch
      • delayErrorMode

        final int delayErrorMode
        How to handle errors from the main and inner Observables. See the constants below.
      • IMMEDIATE

        public static final int IMMEDIATE
        Whenever any Observable fires an error, terminate with that error immediately.
        See Also:
        Constant Field Values
      • BOUNDARY

        public static final int BOUNDARY
        Whenever the main fires an error, wait until the inner terminates.
        See Also:
        Constant Field Values
    • Constructor Detail

      • OnSubscribeConcatMap

        public OnSubscribeConcatMap​(Observable<? extends T> source,
                                    Func1<? super T,​? extends Observable<? extends R>> mapper,
                                    int prefetch,
                                    int delayErrorMode)