如何在RxJS中依次发起请求直至找到符合条件的响应

你的需求是按顺序发起请求，每个请求返回后检查active字段：

• 若active为true，立即停止后续请求并返回对应的info
• 若active为false，继续发起下一个请求

原代码的问题在于直接将所有请求存入数组，会一次性发起全部请求，无法实现“顺序执行+满足条件终止”的逻辑。以下是基于RxJS的解决方案：

实现代码 #

import { concat, of } from 'rxjs';
import { first, map } from 'rxjs/operators';

const children = action['children'];

// 构建按顺序执行的请求流
const sequentialRequests$ = concat(
  ...children.map(child => this.myService.fakeChildService(child))
);

sequentialRequests$
  .pipe(
    // 捕获第一个active为true的响应，若全部为false则返回默认值
    first(
      (response) => response.active,
      { active: false, info: '无有效结果' } // 可根据需求调整默认值
    ),
    // 提取需要的info字段
    map(response => response.info)
  )
  .subscribe({
    next: (info) => {
      // 处理最终得到的info
      console.log('结果:', info);
    },
    error: (error) => {
      // 处理请求过程中的错误
      console.error('请求失败:', error);
    }
  });

代码说明 #

1. 顺序执行控制：使用concat操作符将多个Observable按顺序组合，只有前一个请求完成后才会发起下一个，确保请求按顺序执行。
2. 终止逻辑：first操作符会在第一个满足response.active === true的响应时立即发出该值并终止整个流，后续请求不会再被触发。
3. 默认值处理：first的第二个参数是默认返回值，当所有请求的active都为false时，会返回这个默认值，避免流无输出。
4. 结果提取：通过map操作符从响应中提取需要的info字段，简化后续处理。

如果不需要默认值，可移除first的第二个参数，此时若所有请求都返回false，subscribe的next回调不会触发，只会触发complete回调：

sequentialRequests$
  .pipe(
    first((response) => response.active),
    map(response => response.info)
  )
  .subscribe({
    next: (info) => console.log('结果:', info),
    error: (error) => console.error('请求失败:', error),
    complete: () => console.log('所有请求均返回active: false')
  });

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