Angular RxJS 嵌套订阅多个 Http 请求

Question

我想知道在一个接一个地发出 http 请求时的最佳做法是什么，特别是，我将被要求使用第一个请求的 return 值。目前，我有一个嵌套订阅来解决这个问题[见下面的代码]。

我尝试使用 RxJS 的 siwtchMap、mergeMap 和 concat，但它似乎没有用。任何建议都会有所帮助。

onStartUp() {
    this.recordingService.getRecording(this.id)
     .subscribe(x => {
       this.recording = x;
       const params = new Chunk(this.recording, 0, 30);
       this.recordingService.getSignal(params)
        .subscribe(data => console.log(data));
     });
  }

Answer 1

为什么 switchMap 在您的情况下不起作用？我认为这是最好的解决方案，switchMap 接收流的结果并且 return 另一个可观察到的继续流：

onStartUp() {
   this.recordingService.getRecording(this.id)
   .switchMap((x) => {
       this.recording = x;
       const params = new Chunk(this.recording, 0, 30);
       return this.recordingService.getSignal(params);  
   })
   .subscribe(data => console.log(data));
 }

如果您使用的是管道运算符：

import { switchMap } from 'rxjs/operators';

this.recordingService.getRecording(this.id)
  .pipe(
      switchMap((x) => {
          this.recording = x;
          const params = new Chunk(this.recording, 0, 30);
          return this.recordingService.getSignal(params);  
      })
  )
  .subscribe(data => console.log(data));

Angular RxJS 嵌套订阅多个 Http 请求

Angular RxJS Nested Subscribe with multiple Http Requests

http

rxjs

angular

rxjs6