javascript - 使用 Observables 发出同步 http 请求

Question

我正在从事 Angular 2 项目。我必须发出 n 个 http 请求。但是我需要等待从上一个请求中获取数据才能发出下一个请求。

如何使用 Observables 实现这一目标。

我在做:

_.forEach(data, (path) => {
        this.userService.getTreeNodes(path.id)
          .subscribe(
            data => {
              //do something
            }
          );
      });

所以现在，三个同时的请求正在进行中。

Answer 1

flatMap - 运算符是关键字，可以帮助您解决问题。

flatMap 是我们处理可观察对象之间依赖关系的方式。我的示例是人为设计的，但我从第一个可观察对象返回一个值，第二个可观察对象计算总和所需的值。

就像我说的，这个例子是人为设计的，但如果我们将其与 promise 进行比较，flatMap 就是我们创建 promise 链的等价物的方式。代码如下所示。

let first = Observable.of(10);
first.flatMap((operand1) => {
  return Observable.of(operand1 + 10);
})
.subscribe(res => this.flatMappedStreams = {msg: '10 + 10 = ' + res});

来源自http://www.syntaxsuccess.com/viewarticle/combining-multiple-rxjs-streams-in-angular-2.0