From e4fa1e69e7ebfb627c7198fd1a9881e9327ec4d4 Mon Sep 17 00:00:00 2001 From: Pinapelz Date: Sat, 28 Jun 2025 17:26:46 -0700 Subject: initial commit: scaffolding --- node_modules/rxjs/src/internal/operators/zipAll.ts | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) create mode 100644 node_modules/rxjs/src/internal/operators/zipAll.ts (limited to 'node_modules/rxjs/src/internal/operators/zipAll.ts') diff --git a/node_modules/rxjs/src/internal/operators/zipAll.ts b/node_modules/rxjs/src/internal/operators/zipAll.ts new file mode 100644 index 0000000..697cff5 --- /dev/null +++ b/node_modules/rxjs/src/internal/operators/zipAll.ts @@ -0,0 +1,20 @@ +import { OperatorFunction, ObservableInput } from '../types'; +import { zip } from '../observable/zip'; +import { joinAllInternals } from './joinAllInternals'; + +/** + * Collects all observable inner sources from the source, once the source completes, + * it will subscribe to all inner sources, combining their values by index and emitting + * them. + * + * @see {@link zipWith} + * @see {@link zip} + */ +export function zipAll(): OperatorFunction, T[]>; +export function zipAll(): OperatorFunction; +export function zipAll(project: (...values: T[]) => R): OperatorFunction, R>; +export function zipAll(project: (...values: Array) => R): OperatorFunction; + +export function zipAll(project?: (...values: T[]) => R) { + return joinAllInternals(zip, project); +} -- cgit v1.2.3