Skip to main content

RxJS Overview

Common Scenarios​

Sequential​

RxJs equivalent to a promise's .then() functionality: mergeMap

// TODO: Add example - @russell.green
this.saveLayoutChanges()
  .pipe(
    // Save sharing changes will not occur
    // until after 'saveLayoutChanges' emits.
    mergeMap(entity => this.saveSharingChanges())
  )
  .subscribe(valueFromSharingSave => {
    // Triggered after both sources emit.
  });

f​

RxJs Promise.all() equivalent: forkJoin

const request1 = this.http.get('/api/hello'); // returns an observable
const request2 = this.http.get('/api/there'); // returns an observable

forkJoin([request1, request2]).subscribe(response => {
  // Called after all the successful requests
  // response.forEach((eachRes)=>{console.log(eachRes)});
  // or response[0] , response[1]
});

Resources​