如何使用RxJS优化递归检查状态直至Available的函数？

针对你的需求，我们可以用RxJS的操作符组合替代原生递归定时器，实现更简洁、可控的状态轮询逻辑：

核心实现代码 #

import { defer, of } from 'rxjs';
import { delay, retryWhen, filter, take } from 'rxjs/operators';

// 包装状态检查逻辑，确保每次重试都获取最新状态
const statusCheck$ = defer(() => {
  const currentStatus = this.updateStatus(); // 调用你的状态更新/获取函数
  return of(currentStatus);
});

// 启动轮询
statusCheck$
  .pipe(
    // 仅当状态为Available时才放行，其他状态进入重试流程
    filter(status => status === 'Available'),
    // 拿到第一个Available状态后立即终止流
    take(1),
    // 处理重试逻辑
    retryWhen(error$ => 
      error$.pipe(
        // 根据上次的状态动态设置重试延迟
        delayWhen(lastStatus => {
          return of(null).pipe(delay(lastStatus === 'Pending' ? 0 : 2000));
        })
      )
    )
  )
  .subscribe({
    next: () => console.log('状态已变为Available'),
    complete: () => console.log('轮询结束')
  });

针对异步updateStatus的适配 #

如果updateStatus是返回Promise的异步函数，只需要把of(currentStatus)替换为from(this.updateStatus())即可：

import { defer, from } from 'rxjs';
// ...其余操作符不变

const statusCheck$ = defer(() => from(this.updateStatus()));

关键操作符说明 #

• defer：避免复用初始状态，确保每次重试时都会重新调用updateStatus获取最新值
• filter：过滤出目标状态，非目标状态会触发重试逻辑
• take(1)：拿到第一个Available状态后立即终止轮询，防止不必要的后续请求
• retryWhen + delayWhen：捕获非目标状态，根据状态动态设置重试延迟时间，实现和原生代码一致的逻辑

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