aboutsummaryrefslogtreecommitdiffstats
path: root/node_modules/rxjs/dist/esm/internal/operators/mergeMap.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/rxjs/dist/esm/internal/operators/mergeMap.js')
-rw-r--r--node_modules/rxjs/dist/esm/internal/operators/mergeMap.js15
1 files changed, 15 insertions, 0 deletions
diff --git a/node_modules/rxjs/dist/esm/internal/operators/mergeMap.js b/node_modules/rxjs/dist/esm/internal/operators/mergeMap.js
new file mode 100644
index 0000000..fc2d2fd
--- /dev/null
+++ b/node_modules/rxjs/dist/esm/internal/operators/mergeMap.js
@@ -0,0 +1,15 @@
+import { map } from './map';
+import { innerFrom } from '../observable/innerFrom';
+import { operate } from '../util/lift';
+import { mergeInternals } from './mergeInternals';
+import { isFunction } from '../util/isFunction';
+export function mergeMap(project, resultSelector, concurrent = Infinity) {
+ if (isFunction(resultSelector)) {
+ return mergeMap((a, i) => map((b, ii) => resultSelector(a, b, i, ii))(innerFrom(project(a, i))), concurrent);
+ }
+ else if (typeof resultSelector === 'number') {
+ concurrent = resultSelector;
+ }
+ return operate((source, subscriber) => mergeInternals(source, subscriber, project, concurrent));
+}
+//# sourceMappingURL=mergeMap.js.map \ No newline at end of file
send patches to the email below
yukais@pinapelz.com
include the subject [PATCH repo_name]
pinapelz.com
homepage