rx.internal.operators

Class OperatorMergeMaxConcurrent<T>

  • Type Parameters:
    T - the emitted value type
    All Implemented Interfaces:
    Func1<Subscriber<? super T>,Subscriber<? super Observable<? extends T>>>, Function, Observable.Operator<T,Observable<? extends T>> 

    public final class OperatorMergeMaxConcurrent<T>
extends Object
implements Observable.Operator<T,Observable<? extends T>>
    Flattens a list of Observables into one Observable sequence, without any transformation.

    You can combine the items emitted by multiple Observables so that they act like a single Observable, by using the merge operation.

    • Constructor Detail

      • OperatorMergeMaxConcurrent

        public OperatorMergeMaxConcurrent(int maxConcurrency)