Class OnSubscribeConcatMap<T,R>

java.lang.Object
rx.internal.operators.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 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 Details

    • source

      final Observable<? extends T> source
    • mapper

      final Func1<? super T,? extends Observable<? extends R>> mapper
    • 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:
    • BOUNDARY

      public static final int BOUNDARY
      Whenever the main fires an error, wait until the inner terminates.
      See Also:
    • END

      public static final int END
      Delay all errors to the very end.
      See Also:
  • Constructor Details

    • OnSubscribeConcatMap

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