如何将发出数组的可观测值转换为单独发出数组的每个值的可观测值？

Question

我使用的是RXFire和RXJS。

collectionData(firebase.firestore.collection('collectionname')).subscribe(x=>console.log(x)

返回

// [{document1}, {document2}]

我想要的是一个可以观察到的返回

// {document1}
// {document2}

我尝试使用from()和toArray()的组合(即将可观测的数组转换为普通数组，然后返回到一个逐个发出每个文档的可观测数组)，但是toArray()只创建了一个可观测的数组，而不是一个实际的数组。我需要一个与toArray()相反的操作。将一个可观测的数组发射出来，并将其转化为一个可观察的数组，它可以单独地发出每个值。

我该怎么做？

编辑：

我还试着做了这样的事

const newObs = oldObs.subscribe(x => from(x))

但这会存储订阅者，而不是新的可观察到的人。=(

Answer 1

有多种方法可以做到这一点。例如：

collectionData(firebase.firestore.collection('collectionname'))
  .pipe(
    concatAll(),
  )
  .subscribe();

您也可以使用concatMap(array => array)。

而不是concat*，您也可以使用merge*。