Question

32

Rxjs One Observable Feeding into Another

rated 0 times [ 39] [ 7] / answers: 1 / hits: 42974 / 7 Years ago, fri, june 16, 2017, 12:00:00

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!

Answers

Only authorized users can answer the question. Please sign in first, or register a free account.

tylerdamiena

Add To Favorites

Follow

Total Points: 139

Total Questions: 90

Total Answers: 118

Location: Liechtenstein

Member since Wed, Dec 8, 2021

3 Years ago

tylerdamiena questions

1 How to access sveltekit session in endpoint?

Tue, May 3, 22, 00:00, 2 Years ago

1 React.js, Each child in a list should have a unique key prop. how to fix if key is already given

Mon, Mar 7, 22, 00:00, 2 Years ago

1 Can`t resolve image.png in styles.css

Fri, Sep 17, 21, 00:00, 3 Years ago

1 Warning: validateDOMNesting(...): < body> cannot appear as a child of < div> in React.js

Wed, May 26, 21, 00:00, 3 Years ago

1 Using readonly on a reactive object

Tue, May 26, 20, 00:00, 4 Years ago

View All

answered 7 Years ago serena · Accepted 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