使用RXJS和AsyncPipe而不是observable.subscribe

Question

在我的firebase(angularfire2)应用程序中，我希望为集合的每个元素返回文档。为此，我使用Observables+.subscribe()。但我想使用RXJ和AsyncPipe获得替代方案。

this.shortlisted$ = this.db.collection(`interestingStartups`).valueChanges().pipe(mergeMap(actions => actions.map(el => {
 return this.db.doc(`startups/${(<any>el).startupUid}`).valueChanges().pipe(mergeMap(el => of([el])));
})));

并在HTML模板中使用*ngfor=“let s of shortlist$async”。但不起作用。Angular显示下一个错误“找不到类型为”object“的不同支持对象”[object object]“。NgFor仅支持绑定到可迭代对象（如数组）”

我的当前代码（Observables+.Subscribe):

this.db.collection('interestingStartups').valueChanges().subscribe((el:any) => {
 el.forEach(is => {
  this.db.doc('startups/' + is.startupUid).get().subscribe(s => {
   this.shortlisted.push(s.data());
  })
 })        
});

而且我只使用纯的*ngfor而不使用AsyncPipe，即*ngfor=“let s of shortlisted”

我希望使用类似mergemap或类似的RXJS运算符将结果分配到this.shortlist中。在目前的时刻，我无法找到有效的解决办法

请救命！

Answer 1

这个应该管用。

this.shortlisted$ = this.db.collection('interestingStartups').valueChanges().pipe(
  switchMap(el => combineLatest(
    el.map(is => this.db.doc('startups/' + is.startupUid).get())
  ))
);

它首先获取interestign启动的列表，然后对于每个启动，获取该启动的文档，并使用combineLatest将它们连接起来。