Function operatorForMode

  • Returns the RxJS operator corresponding to the plain English concurrency mode. Useful for creating a service whose (fixed) concurrency is known just at runtime.

    Parameters

    Returns {
        <T, O>(project, concurrent?): OperatorFunction<T, ObservedValueOf<O>>;
        <T, O>(project, resultSelector, concurrent?): OperatorFunction<T, ObservedValueOf<O>>;
        <T, R, O>(project, resultSelector, concurrent?): OperatorFunction<T, R>;
    } | (<T, R, S>(workCreator, mapper?) => OperatorFunction<T, S>)