mituri

[NGRX] combineLatest

Feb 25th, 2020
186
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.71 KB | None | 0 0
  1. /*
  2. Including https://unpkg.com/@reactivex/[email protected]/dist/global/rxjs.umd.js
  3. in index.html's script tag gives us rxjs globally available under window.rxj
  4. */
  5. const { Observable, of, combineLatest } = rxjs
  6. const { tap, map, first, takeUntil, catchError } = rxjs.operators
  7.  
  8. const observableFirst$ = Observable.create((observer) => {
  9. observer.next(1)
  10. observer.next(2)
  11. observer.next(3)
  12. })
  13.  
  14. const observableSecond$ = Observable.create((observer) => {
  15. observer.next('a')
  16. observer.next('b')
  17. observer.next('c')
  18. })
  19.  
  20. combineLatest(
  21. observableFirst$,
  22. observableSecond$
  23. ).subscribe(([numberVal, letterVal]) => {
  24. console.log('numberVal', numberVal)
  25. console.log('letterVal', letterVal)
  26. })
Add Comment
Please, Sign In to add comment