如何从snapshotChanges()或valueChanges()中获取新增对象？

看起来你想从activity集合的snapshotChanges()里只拿到最新新增的单个对象来触发本地通知，而不是处理整个文档数组对吧？我来给你调整下代码逻辑：

首先，你已经用orderBy('saved', 'desc')把文档按保存时间倒序排列了，不过要注意snapshotChanges()第一次订阅时会返回所有现有文档的added动作，我们需要区分初始加载和后续新增的情况，避免一开始就触发一堆通知。

这里有个优化后的实现：

constructor(public afs: AngularFirestore) {
  // 监控activity集合，按saved字段倒序排列
  const itemsCollection = this.afs.collection<any>('activity', ref => ref.orderBy('saved', 'desc'));

  itemsCollection.snapshotChanges()
    .pipe(
      // 过滤出新增的文档动作
      map(actions => actions.filter(action => action.type === 'added')),
      // 跳过初始加载的所有文档（如果不需要初始的第一个文档触发通知的话）
      // 如果初始加载时也想拿最新的那个，就去掉skip(1)
      skip(1),
      // 取每次变更里的最新新增文档（因为orderBy是倒序，第一个就是最新的）
      map(addedActions => addedActions[0]),
      // 提取文档数据和ID
      map(action => {
        const data = action.payload.doc.data();
        const id = action.payload.doc.id;
        return { id, ...data };
      })
    )
    .subscribe(newestItem => {
      // 在这里触发本地通知，使用newestItem这个最新的新增对象
      console.log('最新新增的活动:', newestItem);
      // 比如调用你的通知服务：this.notificationService.show(newestItem);
    });
}

关键细节说明： #

• 过滤新增动作：用filter(action => action.type === 'added')只保留新增的文档变更，忽略修改、删除的动作。
• 跳过初始加载：skip(1)会跳过第一次订阅时返回的所有现有文档的批量added动作，只处理之后实时新增的单个文档。如果你希望初始加载时也拿到最新的那个文档，就去掉这个操作符。
• 提取最新对象：因为我们已经按saved倒序排列，所以addedActions[0]就是最新的新增文档。
• 完整文档数据：把文档ID和数据合并返回，这样你能拿到完整的新增对象信息。

如果你的场景里，每次新增只会产生一个added动作（大部分实时新增场景都是这样），也可以简化成直接提取单个动作：

itemsCollection.snapshotChanges()
  .pipe(
    map(actions => actions.find(action => action.type === 'added')),
    filter(Boolean), // 过滤掉undefined（比如没有新增动作的时候）
    skip(1),
    map(action => ({ id: action.payload.doc.id, ...action.payload.doc.data() }))
  )
  .subscribe(newestItem => {
    // 触发通知逻辑
  });

这样就能精准拿到每次新增的最新单个对象，用来触发本地通知啦～

内容的提问来源于stack exchange，提问作者Grant