Skip to content

Commit f6bd51f

Browse files
committed
feat(zipAll): add higher-order lettable version of zipAll
1 parent 509c97c commit f6bd51f

File tree

3 files changed

+10
-2
lines changed

3 files changed

+10
-2
lines changed

src/operator/zipAll.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
1-
import { ZipOperator } from '../operators/zip';
21
import { Observable } from '../Observable';
2+
import { zipAll as higherOrder } from '../operators/zipAll';
33

44
/**
55
* @param project
@@ -8,5 +8,5 @@ import { Observable } from '../Observable';
88
* @owner Observable
99
*/
1010
export function zipAll<T, R>(this: Observable<T>, project?: (...values: Array<any>) => R): Observable<R> {
11-
return this.lift(new ZipOperator(project));
11+
return higherOrder(project)(this);
1212
}

src/operators/index.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -80,3 +80,4 @@ export { windowToggle } from './windowToggle';
8080
export { windowWhen } from './windowWhen';
8181
export { withLatestFrom } from './withLatestFrom';
8282
export { zip } from './zip';
83+
export { zipAll } from './zipAll';

src/operators/zipAll.ts

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
import { ZipOperator } from './zip';
2+
import { Observable } from '../Observable';
3+
import { OperatorFunction } from '../interfaces';
4+
5+
export function zipAll<T, R>(project?: (...values: Array<any>) => R): OperatorFunction<T, R> {
6+
return (source: Observable<T>) => source.lift(new ZipOperator(project));
7+
}

0 commit comments

Comments
 (0)