主页 / coding / 问题 / 78206815
Accepted
syahiruddin
Asked: 2024-03-22 22:13:06 +0800 CST

如何在 Angular/RxJS 中不使用 toArray() 的情况下检索 Observable 末尾的数组？

  • 772

我有一个可观察的丰富_sns$，我通过使用 concatMap 对每个发出的项目执行操作来丰富它，然后使用 toArray() 将结果组合到数组中。但是，我很好奇是否有其他方法可以在不使用 toArray() 的情况下实现相同的结果。

这是我当前的代码：

private enriched_sns$ = toObservable(this.sn_results).pipe(
  concatMap((results) => results as StreamNotificationResult[]),
  concatMap((notification) => {
    const user_id = notification.activities[0].actor.id;
    return zip(of(notification), this.read_user_data_service.readUserData(user_id));
  }),
  map(([notification, user]) => {
    return {
      notification,
      user: user,
    };
  }),
  toArray(),
);

有没有一种方法可以在可观察对象的末尾获取发出的项目数组，而无需诉诸 toArray() ？任何帮助或替代方法将不胜感激。谢谢你！

rxjs

1 个回答

  1. Best Answer

    toArray()您需要在示例中使用的原因是因为您从信号中获取发射的数组，然后单独发射每个元素。

    您可以使用该forkJoin函数来处理订阅一组可观察值，而不是使用concatMap一次发出一个元素：

    private enriched_sns$ = toObservable(this.sn_results).pipe(
  concatMap((results: StreamNotificationResult[]) => forkJoin(
    results.map(n => this.read_user_data_service.readUserData(n.activities[0].actor.id).pipe(
      map(user => ({ notification: n, user }))
    ))
  )),
);

    有一个重要的区别forkJoin是同时订阅所有可观察量，而不是一次订阅一个。如果您需要限制并发，您可以查看rxjs-etc具有forkJoinConcurrent允许您指定并发的函数的包：

    private enriched_sns$ = toObservable(this.sn_results).pipe(
  concatMap((results: StreamNotificationResult[]) => forkJoinConcurrent(
    results.map(n=> this.read_user_data_service.readUserData(n.activities[0].actor.id).pipe(
      map(user => ({ notification: n, user }))
    ))
  ), 1), // <-- limit to one inner subscription at a time
);

    请注意，根本没有必要使用zip/ 。of您可以简单地将 a 添加.pipe到内部可观察值并将发射映射到您想要的形状：

    private enriched_sns$ = toObservable(this.sn_results).pipe(
  concatMap((results: StreamNotificationResult[]) => results),
  concatMap(notification => {
    const user_id = notification.activities[0].actor.id;
    return this.read_user_data_service.readUserData(user_id).pipe(
      map(user => ({ notification, user }))
    );
  }),
  toArray(),
);
    • 1

相关问题