rxjs - Rxjs 递归调用

问题描述

我有以下示例代码，它递归地从某个 REST 资源中提取数据。每个端点都提供以下 JSON 内容

{ data: '123',  urls: ['https//example/bar', 'https//example/bim'] }

我可以构建一个像这样递归地提取内容的 Rx 流：

function getData(url) {
  return fromFetch(url).pipe(    
    mergeMap(resp => resp.json()),
    mergeMap(content => merge(of(content.data), ...content.urls.map(getData)))
  )
}

我的问题是在这里控制 HTTP 调用并发的最佳方法是什么。

这可以通过自定义调度程序来实现吗？
还是我应该简单地将 fromFetch 包装到一个类中，该类控制在任何时间点可以进行多少 HTTP 调用的并发性？

标签： rxjs

由于expand您可能最多只能获得 1 个并发，使用 subject + mergeMap 更容易控制并发，这样您就只有一个通道可以工作。

const fetchSubject=new Subject();
fetchSubject.pipe(
    mergeMap(url=>fromFetch(url),null,CONCURRENCY)    
    mergeMap(resp => resp.json()),
    tap(url=>content.urls.map(url=>fetchSubject.next(url))
    scan((acc,curr) =>{
      return [curr.data,...acc]
    })
  )

rxjs - Rxjs 递归调用 - 并发

问题描述

解决方案

推荐阅读