Rxjs One Observable Feeding into Another

I have a rather clunky looking set of code where the data from one observable is feed into another, like such:

let source = this.myService.getFoo()
   .subscribe(result => {
      let source2 = this.myService.getMoo(result)
         .subscribe(result2 => { // do stuff });
   });

I know that there are ways to combine and chain but I need data from source to be feed into source2. The nesting of subscribes looks terrible and I’m pretty certain there is a better way to do this.

Thanks!

Answer

For transforming items emitted by an Observable into another Observable, you probably want to use the mergeMap operator. It creates an inner Observable and flattens its result to the outer stream.

const source = this.myService
    .getFoo()
    .pipe(
        mergeMap(result => this.myService.getMoo(result))
     )
    .subscribe(result2 => {
        // do some stuff
    });

Here are some flat operators you can use that behave differently:

• mergeMap – creates an Observable immediately for any source item, all previous Observables are kept alive. (this was formerly known as flatMap).
• concatMap – waits for the previous Observable to complete before creating the next one
• switchMap – for any source item, completes the previous Observable and immediately creates the next one
• exhaustMap – map to inner observable, ignore other values until that observable completes