相关疑难解决方法(0)

假设我想下载 10,000 个文件。我可以轻松地构建一个包含这 10,000 个文件的队列（如果其中任何一个可以做得更好，我很乐意接受建议），

import request from 'request-promise-native';
import {from} from 'rxjs';

let reqs = [];
for ( let i = 0; i < 10000; i++ ) {
  reqs.push(
    from(request(`http://bleh.com/${i}`))
  )
};

现在我有一个 Rx.JS observable 数组，我是从代表我的队列的承诺中创建的。现在对于我想要的行为，我想发出

• 三并发请求到服务器
• 完成请求后，我希望触发新的请求。

我可以为这个问题创建一个解决方案，但鉴于我从未使用过的Rxjs queue 之类的东西，我想知道最正确的 Rxjs 方法是什么。