使用 RxJS 一次向服务器发送一个请求

Question

我有一组有效负载，我想在每个负载上执行几个异步操作，然后发送到服务器。我正在尝试这样做：

Rx.Observable.from(payloads)
    .flatMap(item => ... do something A something async, return modified payload)
    .flatMap(item => ... do something B)
    .flatMap(item => ... post to server)
    .subscribe();

这行得通....

但它似乎一次对每个有效负载执行 A，然后对每个有效负载执行一次 B，然后一次性发布每个有效负载。

包含可能数千个有效负载的列表。有没有什么方法可以一次一个地遍历payloads？

Answer 1

如果需要为每个有效负载执行 a->b->c：

Rx.Observable.from(payloads)
  .concatMap(payload => doA())
  .concatMap(resA => doB())
  .concatMap(resB => doC())
  .subscribe(console.log)

concatMap 将等到前一个发射完成后再开始下一个发射。这将限制您的并发性。