Class OperatorEagerConcatMap<T,R>

java.lang.Object
rx.internal.operators.OperatorEagerConcatMap<T,R>
All Implemented Interfaces:
Func1<Subscriber<? super R>,Subscriber<? super T>>, Function, Observable.Operator<R,T>

public final class OperatorEagerConcatMap<T,R> extends Object implements Observable.Operator<R,T>
  • Field Details

    • mapper

      final Func1<? super T,? extends Observable<? extends R>> mapper
    • bufferSize

      final int bufferSize
    • maxConcurrent

      private final int maxConcurrent
  • Constructor Details

    • OperatorEagerConcatMap

      public OperatorEagerConcatMap(Func1<? super T,? extends Observable<? extends R>> mapper, int bufferSize, int maxConcurrent)
  • Method Details