rxjs-branch
v0.3.3
Published
Branch operator for RxJS.
Downloads
21
Readme
Branch Operator for RxJS
Installation
npm install rxjs-branch
Usage
const branches = await firstValueFrom(
range(0, 10).pipe(
branch(
value => value % 2 === 0,
(state, value) => state,
),
mergeMap(value$ =>
value$.pipe(
map(([state, value]) => value),
toArray(),
),
),
toArray(),
),
);
expect(branches).toEqual([
[0, 1, 2, 3, 4, 5, 6, 7, 8, 9],
[2, 3, 4, 5, 6, 7, 8, 9],
[4, 5, 6, 7, 8, 9],
[6, 7, 8, 9],
[8, 9],
]);
License
MIT License.