aboutsummaryrefslogtreecommitdiffstats
path: root/node_modules/rxjs/src/internal/operators/mergeMapTo.ts
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/rxjs/src/internal/operators/mergeMapTo.ts')
-rw-r--r--node_modules/rxjs/src/internal/operators/mergeMapTo.ts74
1 files changed, 0 insertions, 74 deletions
diff --git a/node_modules/rxjs/src/internal/operators/mergeMapTo.ts b/node_modules/rxjs/src/internal/operators/mergeMapTo.ts
deleted file mode 100644
index bcc4654..0000000
--- a/node_modules/rxjs/src/internal/operators/mergeMapTo.ts
+++ /dev/null
@@ -1,74 +0,0 @@
-import { OperatorFunction, ObservedValueOf, ObservableInput } from '../types';
-import { mergeMap } from './mergeMap';
-import { isFunction } from '../util/isFunction';
-
-/** @deprecated Will be removed in v9. Use {@link mergeMap} instead: `mergeMap(() => result)` */
-export function mergeMapTo<O extends ObservableInput<unknown>>(
- innerObservable: O,
- concurrent?: number
-): OperatorFunction<unknown, ObservedValueOf<O>>;
-/**
- * @deprecated The `resultSelector` parameter will be removed in v8. Use an inner `map` instead.
- * Details: https://rxjs.dev/deprecations/resultSelector
- */
-export function mergeMapTo<T, R, O extends ObservableInput<unknown>>(
- innerObservable: O,
- resultSelector: (outerValue: T, innerValue: ObservedValueOf<O>, outerIndex: number, innerIndex: number) => R,
- concurrent?: number
-): OperatorFunction<T, R>;
-/* tslint:enable:max-line-length */
-
-/**
- * Projects each source value to the same Observable which is merged multiple
- * times in the output Observable.
- *
- * <span class="informal">It's like {@link mergeMap}, but maps each value always
- * to the same inner Observable.</span>
- *
- * ![](mergeMapTo.png)
- *
- * Maps each source value to the given Observable `innerObservable` regardless
- * of the source value, and then merges those resulting Observables into one
- * single Observable, which is the output Observable.
- *
- * ## Example
- *
- * For each click event, start an interval Observable ticking every 1 second
- *
- * ```ts
- * import { fromEvent, mergeMapTo, interval } from 'rxjs';
- *
- * const clicks = fromEvent(document, 'click');
- * const result = clicks.pipe(mergeMapTo(interval(1000)));
- *
- * result.subscribe(x => console.log(x));
- * ```
- *
- * @see {@link concatMapTo}
- * @see {@link merge}
- * @see {@link mergeAll}
- * @see {@link mergeMap}
- * @see {@link mergeScan}
- * @see {@link switchMapTo}
- *
- * @param innerObservable An `ObservableInput` to replace each value from the
- * source Observable.
- * @param concurrent Maximum number of input Observables being subscribed to
- * concurrently.
- * @return A function that returns an Observable that emits items from the
- * given `innerObservable`.
- * @deprecated Will be removed in v9. Use {@link mergeMap} instead: `mergeMap(() => result)`
- */
-export function mergeMapTo<T, R, O extends ObservableInput<unknown>>(
- innerObservable: O,
- resultSelector?: ((outerValue: T, innerValue: ObservedValueOf<O>, outerIndex: number, innerIndex: number) => R) | number,
- concurrent: number = Infinity
-): OperatorFunction<T, ObservedValueOf<O> | R> {
- if (isFunction(resultSelector)) {
- return mergeMap(() => innerObservable, resultSelector, concurrent);
- }
- if (typeof resultSelector === 'number') {
- concurrent = resultSelector;
- }
- return mergeMap(() => innerObservable, concurrent);
-}
send patches to the email below
yukais@pinapelz.com
include the subject [PATCH repo_name]
pinapelz.com
homepage