Skip to content

Instantly share code, notes, and snippets.

@armanozak
Created May 3, 2021 09:02
Show Gist options
  • Save armanozak/4d4b9f1a47672bbfe784a078e18bcbd5 to your computer and use it in GitHub Desktop.
Save armanozak/4d4b9f1a47672bbfe784a078e18bcbd5 to your computer and use it in GitHub Desktop.
[What's New in RxJS 7] Observable dictionaries in RxJS 6 forkJoin #blog #rxjs
import { forkJoin, interval } from "rxjs";
import { map } from "rxjs/operators";
const count1To5$ = interval(1000).pipe(
take(5),
map(i => i + 1)
);
const count6To9$ = interval(1000).pipe(
take(4),
map(i => i + 6)
);
forkJoin({ x: count1to5$, y: count6to9$ }).subscribe(console.log);
// (after ~5s) {x: 5, y: 9}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment