Class OperatorEagerConcatMap<T,​R>

    • Field Detail

      • bufferSize

        final int bufferSize
      • maxConcurrent

        private final int maxConcurrent
    • Constructor Detail

      • OperatorEagerConcatMap

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