如何利用RxJS Observable控制HTTP请求调用，避免重复执行回调

现有代码：

this.service.callAPI().subscribe(
  data => {
    callFunction();
  },
  error => {console.log("My mistake")}
);

希望根据条件判断是否调用callAPI()，且无论是否调用该API，最终都执行callFunction()，不想重复编写callFunction()代码（比如避免用if-else分别调用的写法），期望语义上类似：

this.service.callAPI().continueIfCondition(condition).subscribe(
  data => {
    callFunction();
  },
  error => {console.log("My mistake")}
);

即满足条件时跳过callAPI()调用，直接执行subscribe的回调；不满足条件时等待请求响应后再执行回调。询问Observable是否具备这种能力，是否遗漏了相关基础文档。

RxJS 提供了iif操作符，可以完美实现你的需求，无需重复编写代码：

import { iif, of } from 'rxjs';

iif(
  () => condition, // 传入判断条件的函数
  of(null), // 条件为true时，直接发出一个空值Observable，立刻进入next回调
  this.service.callAPI() // 条件为false时，执行API请求
).subscribe({
  next: () => callFunction(), // 无论哪种情况都会执行callFunction
  error: () => console.log("My mistake") // 只有API请求出错时才会触发
});

补充说明 #

• iif是RxJS的基础条件操作符，它会根据传入的条件函数，动态选择返回两个Observable中的一个，完全匹配你“条件满足时跳过API，不满足时执行API”的需求。
• 如果你的条件是会动态变化的（比如在Observable订阅前可能改变），iif的条件函数写法能确保订阅时才判断最新的条件值。
• 这种写法把逻辑完全整合到Observable流中，避免了冗余的if-else分支，符合RxJS的响应式编程思路。

内容的提问来源于stack exchange，提问作者imnotthatrobot