AngularFire firestore get / snapshotchanges / valuechanges 对 observable 的操作不是异步的吗？

Question

您好，我的行为很奇怪。

我正在迭代一些文档并设置一些承诺，即当获取文档时，UI 会更新。

然而，虽然 promise 是原子的，但 firestore / AngularFire 会等待所有的 promise。

例子：

 for (const event of events) {
        this.eventService.getEventActivitiesAndSomeStreams(this.user,
          event.getID(),
          [DataLatitudeDegrees.type, DataLongitudeDegrees.type])
          .pipe(take(1)).toPromise().then((fullEvent) => {
            this.logger.info(`Promise completed`)
           
          })
      }

人们会期望随着数据的到来，对于每个承诺，它会慢慢打印完成的承诺。

但是它们都被打印一次。看起来这些承诺不是一个接一个，而是“一次完成”。在打印第一个控制台日志之前，等待时间很长，然后所有的 Promise 都会打印出来。

所以我希望如果我有一个进度条会增加一点点但很少但会立即增加

内部调用this.eventService.getEventActivitiesAndSomeStreams

return this.afs
        .collection('users')
        .doc(userID)
        .collection('events')
        .doc(eventID)
        .collection('activities')
        .doc(activityID)
        .collection('streams', ((ref) => {
          return ref.where('type', 'in', typesBatch);
        }))
        .get()
        .pipe(map((documentSnapshots) => {
          return documentSnapshots.docs.reduce((streamArray: StreamInterface[], documentSnapshot) => {
            streamArray.push(this.processStreamDocumentSnapshot(documentSnapshot)); // Does nothing rather to create an class of the JSON object passed back from the firestore
            return streamArray;
          }, []);
        }))

现在，如果我在 for 循环中放置一个 await，当然这可以正常工作并完成应有的承诺，但是这需要很多时间。

我也试过不使用AngularFire，使用原生的JS SDK效果一样。

我怀疑 IndexedDB 可能会导致这个或其他一些 Firebase 逻辑。

我在这里缺少什么，如果可能的话，我怎样才能获得所需的行为？

您可以通过 ["users" -> "events" -> "something"] firestore 集合复制此内容，如果每个“用户”有 500 个“事件”，并且每个事件还有 2 个文档。

因此，为用户获取所有事件并尝试为每个事件做出一个承诺，该承诺将在 for 数组中返回 2 个“某物”文档）

Answer 1

这种行为是意料之中的，与 firebase 毫无关系。您正在遍历数组并发送请求。项目之间没有等待或延迟，因此 for 循环（没有 await 语句）将在极短的时间内完成，这意味着所有请求都在几毫秒内发送出去，或者基本上同时发送.所以他们的回应也应该基本同时到达。

您已声明不想使用 await 语句并逐个迭代，因此很难确切知道您想要或期望发生什么。也许您希望它们相隔 0.5 秒？如果是这样，您需要编写该逻辑：

timer(0, 500).pipe( // put whatever ms time between requests you want here?
  take(events.length),
  switchMap(i => {
    return this.eventService.getEventActivitiesAndSomeStreams(this.user,
      events[i].getID(),
      [DataLatitudeDegrees.type, DataLongitudeDegrees.type]).pipe(take(1))
  })
).subscribe(fullEvent => {
  this.logger.info(`Promise completed`)
})

（删除的承诺会导致 idk 为什么首先使用它们，而使用 rxjs IMO 更容易进行这种控制）