RxJs Observables imbriqués les abonnements?

Quel est le moyen de simplifier quelque chose comme l'exemple de code suivant?
Je ne peux pas trouver le bon opérateur.. quelqu'un pourrait-il donner un court exemple?

this.returnsObservable1(...)
  .subscribe(

    success => {

      this.returnsObservable2(...)
        .subscribe(

          success => {

            this.returnsObservable3(...)
              .subscribe(

                success => {
                   ...
                },
Vous êtes probablement à la recherche pour flatMap ou switchMap de l'opérateur.

OriginalL'auteur Max Solid | 2017-03-19

  1. 16

    Comme mentionné dans les commentaires, vous êtes à la recherche pour le flatMap opérateur.

    Vous pouvez trouver plus de détails dans les réponses précédentes :

    Votre exemple de lecture :

    this.returnsObservable1(...)
  .flatMap(success => this.returnsObservable2(...))
  .flatMap(success => this.returnsObservable3(...))
  .subscribe(success => {(...)});

    OriginalL'auteur user3743222

  2. 6

    La switchMap opérateur peut également être utile.
    Quelques exemples qui décrivent l'utilité de switchMap par rapport à imbriqués les abonnements peuvent être trouvés ici:

    1. situation avec imbriqué abonnements

    Ce codepen donne une démonstration:
    https://codepen.io/anon/pen/zdXBvP?editors=1111

    Rx.Observable
  .interval(5000)
  .subscribe((val) => {
    console.log("outer:", val);
    Rx.Observable
      .interval(1000)
      .subscribe((ival) => {
        console.log("inner:", val, ival); 
      });
  });
    1. situation avec switchMap

    Ce codepen donne une démonstration:
    https://codepen.io/anon/pen/xLeOZW?editors=1111

    Rx.Observable
  .interval(5000)
  .switchMap((val) => {
    console.log("outer:", val);
    return Rx.Observable.interval(1000).map((ival) => [val, ival]);
  })
  .subscribe((val) => {
    console.log("inner:", val[0], val[1]);
  });
    Les exemples ne sont pas nécessairement assez, mais merci pour le partage.
    Une tendance générale que j'ai trouvé est à remplacer tous les "souscrit" avec "switchMap" le retour le lendemain intérieure Observables. Puis clouez les plus imbriqués "s'abonner" sur la fin de la chaîne

    OriginalL'auteur sdec

  3. 5

    Déjà répondu pour RxJS 5, je suis tombé sur cette page, tout en utilisant 6.

    Dans le cas où vous êtes sur 6 (et je pense que vous devriez être maintenant), vous pouvez utiliser flatmap comme un opérateur dans pipe.

    Modifié le code de l'exemple de @user3743222:

    this.returnsObservable1(...)
  .pipe(
    flatMap(success => this.returnsObservable2(...)),
    flatMap(success => this.returnsObservable3(...))
  )
  .subscribe(success => {(...)});

    OriginalL'auteur Mathijs Segers