観測可能なサブスクリプションを別の観測可能なサブスクリプションにネストすることは可能ですか？

Question

私はAngular2のオブザーバブルの周りに頭を浮かべるのに苦労しています。私はobservable forEachの中でobservableに2つのサブスクリプションを持っています。以下のように、それはだ

：

1. forEachのルートID（ポーリングID）
2. （1でネストされた）を取得購読ルート ID（ポーリングID）
を使用して、データベースからの投票を取得します（2内にネスト）
3. 購読は ポーリングIDはあなたが起こってネスティングの多くがあります見ることができるよう

をcreatedById使用してデータベースからCREATEDBYのユーザーを取得しますちょうどいい気分にはならない。これを達成するためのよりよい方法がありますか？

poll: Poll; 
createdBy: string; 

constructor(public route: ActivatedRoute, public teamPollsService: TeamPollsService) { } 

ngOnInit(): void { 
let id: any; 

// 1. 
this.route.params.forEach((params: Params) => { 
    id = params['id']; 

    // 2. 
    this.pollService.getPoll(id).subscribe((x) => { 
     this.poll = x; 

     // 3. 
     this.users.getDbUser(x.createdById).subscribe((user) => { 
     createdBy = `${user.firstName} ${user.lastName}`; 
     }); 
    }); 
}); 

ありがとう：

は、これは私のコードです。代わりに

Answer 1

使用flatMap()：

this.route.params 
    .flatMap((params: Params) => { 
     id = params['id']; 
     return this.pollService.getPoll(id); 
    }) 
    .flatMap((x) => { 
     this.poll = x; 
     return this.users.getDbUser(x.createdById); 
    }) 
    .subscribe((user) => { 
     createdBy = `${user.firstName} ${user.lastName}`; 
    }); 

それは自動的にアンラップネストされた観測とcallback hellに似た問題を回避するのに役立ちますでしょう。

Answer 2

これはRxには適していない可能性があります。 これは、すべてのサブスクリプションで副作用があり、副作用をflatMapまたはswitchMapで実行することは、他の演算子が関係しているときに実行する回数を予測できないためには理想的ではありません純粋な関数でなければなりません。

Typescriptを使用していることがわかりますが、これらのコールバックをすべて避けるにはasync/awaitを使用する必要があります。