RxJs在阵列中可观测

Question

我正在使用angularfire，我得到了一个连续的阵列流，其中包含任务ID。我需要获取数组中每个id的任务文档作为一个新的可观察的。然后将任务文档数组返回到流中，这样我就可以在组件中订阅它并显示任务列表。

到目前为止，我用mergeMap得到了它。我分割阵列，获取任务文档并将它们返回到流中。我的解决方案唯一的问题是，当我订阅可观察到的时，我没有得到一系列任务，但每个任务都是一个单一的变化，我不能循环使用ngFor。在这种情况下，使用toArray（）操作符不起作用，因为它是一个永不结束的连续流。

到目前为止，这是我的代码：

this.db.collection(`games/${gameId}/missions`).valueChanges().pipe(
    mergeMap(missions => missions),
    mergeMap((mission: any) => {
        return this.db.doc(`missions/${mission.id}`).snapshotChanges();              
    }),
);

这将在单个事件中生成以下输出：

{ id: 1, missionProperties }
{ id: 2, missionProperties }
{ id: 3, missionProperties }

但我想把它作为一系列任务：

[
    { id: 1, missionProperties },
    { id: 2, missionProperties },
    { id: 3, missionProperties }
]

Answer 1

可以使用缓冲区运算符https://www.learnrxjs.io/operators/transformation/buffer.html

of(1, 2, 3, 4, 5).pipe(
  bufferCount(5),
).subscribe(x => console.log(x)); // prints [1, 2, 3, 4, 5]

编辑：

我刚刚看到toArray（）操作符：

of(1, 2, 3, 4, 5).pipe(
  toArray(),
).subscribe(x => console.log(x));

编辑2：

of(1, 2, 3, 4, 5).pipe(
  scan((acc, curr) => { acc.push(curr); return acc; }, []),
).subscribe(x => console.log(x)); // prints [1] [1,2] [1,2,3]....

Answer 2

使用扫描运算符聚合

this.db.collection(`games/${gameId}/missions`).valueChanges().pipe(
  switchMap(missions =>
      from(missions).pipe(
        mergeMap(mission => this.db.doc(`missions/${mission.id}`).snapshotChanges()),
       scan((acc, curr) => [curr, ...acc], [])
      ),
)