为什么在尝试执行请求 Observable 时返回？

Question

我是 rxjs 的新手，正在尝试做两个请求。当我尝试查看结果时，我得到了 Observable。

copy() {
    const obj = {};

    this.create(skill)
      .pipe(
        mergeMap((res) => {
          return [res, forkJoin(this.levels.map((level) => this.level(level)))];
        }),
      )
      .subscribe((res) => {
        console.log(res);
      });
  }

level(level) {
    return this.create(level);
  }

输出： 创造技能的对象， 可观察的 {_isScalar: false, _subscribe: ƒ}

我正常收到第一个请求的响应，而第二个请求以“可观察”的形式出现。

Answer 1

我不完全确定我理解你想要做什么:-)

你传递给mergeMap() 的函数应该“通常”返回一个 observable。目前，您正在返回一个数组。

• 当您返回array 时，mergeMap 将简单地发出每个数组元素；这就是为什么您会收到created skill、Observable 这两个发射。
• 但是，如果您返回 Observable，mergeMap 将订阅它并发出。

我认为这可能适合你：

copy() {
  this.create(skill).pipe(
    mergeMap(createdSkill => forkJoin(this.levels.map(l => this.level(l))).pipe(
      map(createdLevels => ([createdSkill, createdLevels]))  
    )
  )
  .subscribe(
    ([skill, levels]) => console.log({skill, levels})
  );
}

如果我们把它分解成更小的块，可能会更容易理解：

createLevels() { 
    return forkJoin(this.levels.map(l => this.level(l));
}

copy() {
  this.create(skill).pipe(
    mergeMap(createdSkill => createLevels()).pipe(
      map(createdLevels => ([createdSkill, createdLevels]))  
    )
  )
  .subscribe(
    ([skill, levels]) => console.log({skill, levels})
  );
}

这样看来，我们似乎可以用更简单的方式构建 copy() 方法：

copy(skill) {
  forkJoin(
    this.createSkill(skill),
    this.createLevels()
  )
  .subscribe(
    ([skill, levels]) => console.log({skill, levels})
  );
}

Answer 2

ForkJoin 可能不是这里的最佳运算符。我建议看看operator decision tree。我相信你想要这样的东西吗？

 copy() {
    const obj = {};

    forkJoin(
       [
          this.create(skill),
          ...this.levels.map((level) => this.level(level))
       ]
    ).subscribe((res) => {
       console.log(res);
    });
  }

  level(level) {
    return this.create(level);
  }