RXJS-Angular：如何等待一个可观察的函数，调用另一个返回可观察的函数？

Question

在一个服务中，我有两个API调用，每个调用都返回一个可观察的，在我的组件中，我有一些条件，如果为true，我必须调用这两个函数，但我需要等待get（）调用，这样我就可以使用get调用返回的参数执行post函数。如果为false，我只想用已经定义的参数调用post函数。

服务：

  get(id: string) {
    return this.http.get<any>('get path');
  }

  post(data: data) {
    return this.http.post<any>('post path', {data: data});
  }

组成部分：

  execute() {
    if (condition) {
      this.service.get(id).subscribe( (res) =>
        // ...
        this.data = res.data;
        post(data).subscribe(() => // do stuff...);
      );
    } else { post(data).subscribe(() => // do stuff...); }
   }

我不想重复帖子调用的代码，或者如果不可能的话，只是不要在另一个订阅（）中使用订阅（）。我怎么能这么做？没有异步等待。

提前谢谢

Answer 1

另一个解决方案可能如下所示：

const source$ = condition
  ? this.service.get(id) // Get new data
  : of(this.data); // Use already defined data

source$.pipe(
  concatMap(data => this.service.post(data)), 
)

Answer 2

您可以使用RxJSswitchMap操作符从一个可观察对象映射到另一个可观察对象（在您的例子中是GET to POST），并使用RxJSiif函数有条件地返回一个可观察对象。

试试下面的方法

js prettyprint-override">execute() {
  const getPost$ = this.service.get(id).pipe(
    switchMap((res: any) => {
      this.data = res.data;
      return this.service.post(data);
    })
  );


  iif(
    () => condition,
    getPost$,
    this.service.post(data)
  ).subscribe(
    (res: any) => { 
      // handle response
    },
    (error: any) => {
      // handle error
    }
  );
}