RxJs 6如何实现Observable轮询？迁移RxJs 5.2.0旧代码遇阻

嘿，这个问题我太熟了！RxJS 6做了不少破坏性更新，直接把旧版的链式写法给废掉了，不过改起来其实挺简单的，咱们一步步来：

首先得搞清楚RxJS 6的核心变化：

• 不再支持Observable.interval这种静态方法调用，所有创建类的方法（比如interval、of、from）都要从rxjs包单独导入
• 操作符（比如startWith、switchMap）不能直接链式挂在Observable实例上了，必须放到pipe()方法里，而且这些操作符要从rxjs/operators单独导入

接下来就是修改你的代码，先处理导入：

// 导入创建Observable的方法和需要的操作符
import { interval } from 'rxjs';
import { startWith, switchMap } from 'rxjs/operators';

然后是轮询的核心代码，改成用pipe()串联操作符的写法：

interval(5000)
  .pipe(
    startWith(0), // 让轮询一开始就触发第一次请求，不用等5秒
    switchMap(() => this.apiService.getData()) // 每次间隔时间到了就发起请求
  )
  .subscribe(data => {
    // 这里和你原来的逻辑一样，处理返回的数据就行
  });

这样写在RxJS 6+里就能正常运行了！

额外给你补个实用的小扩展：如果你的请求可能出错，或者需要手动停止轮询，可以加上错误处理和停止控制：

import { interval, Subject } from 'rxjs';
import { startWith, switchMap, catchError, takeUntil } from 'rxjs/operators';

// 创建一个Subject用来控制轮询停止
const stopPolling$ = new Subject<void>();

interval(5000)
  .pipe(
    startWith(0),
    switchMap(() => this.apiService.getData().pipe(
      catchError(err => {
        // 请求出错时的处理，比如打日志，返回空流保证轮询不中断
        console.error('获取数据失败:', err);
        return [];
      })
    )),
    takeUntil(stopPolling$) // 当stopPolling$发出值时，立即停止轮询
  )
  .subscribe(data => {
    // 处理数据
  });

// 想要停止轮询的时候调用这两行
// stopPolling$.next();
// stopPolling$.complete();

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