如何在RxJS中动态修改Observable的重复延迟时间？

这问题我熟，要实现动态调整repeatWhen里的请求间隔，核心是把固定的延迟值换成可响应变化的数据源，让RxJS能实时感知到延迟的更新。用RxJS的BehaviorSubject就刚好能搞定——它既能存当前值，又能在值变的时候通知所有订阅者。

完整实现步骤 #

1. 定义可响应的延迟数据源
   先创建一个BehaviorSubject来保存当前的延迟时间，初始值设为你原来的2000ms：

   import { BehaviorSubject } from 'rxjs';
   import { repeatWhen, switchMap, timer } from 'rxjs/operators';
   
   // 组件/service内定义
   private delaySubject = new BehaviorSubject<number>(2000);
   

2. 重构请求的Observable逻辑
   把原来的repeatWhen逻辑改成依赖delaySubject的最新值，每次要重复请求时，都用当前的延迟值来触发：

   // 构建重复请求流
   const observ = this.myService.getData().pipe(
     repeatWhen(completed => 
       completed.pipe(
         // 每次源请求完成后，拿最新的延迟值生成定时器
         switchMap(() => timer(this.delaySubject.value))
       )
     )
   );
   
   // 订阅请求结果
   this.mySubscription = observ.subscribe(val => this.handleResponse(val));
   

3. 动态修改延迟值
   不管是在handleResponse方法里，还是其他任何地方，只要调用delaySubject.next()就能更新延迟，下次重复请求就会用新的间隔：

   handleResponse(val: any) {
     // 示例：根据返回数据动态调整延迟
     if (val.isUrgent) {
       this.delaySubject.next(1000); // 缩短到1秒
     } else {
       this.delaySubject.next(5000); // 延长到5秒
     }
   }
   
   // 也可以通过外部事件修改，比如按钮点击
   updateDelay(newDelay: number) {
     this.delaySubject.next(newDelay);
   }
   

4. 清理资源（重要）
   如果是在Angular组件里使用，记得在组件销毁时取消订阅并关闭BehaviorSubject，避免内存泄漏：

   import { OnDestroy } from '@angular/core';
   
   export class YourComponent implements OnDestroy {
     // ... 其他代码
   
     ngOnDestroy() {
       this.mySubscription?.unsubscribe();
       this.delaySubject.complete();
     }
   }
   

原理说明 #

repeatWhen的回调函数会在源Observable每次完成时收到通知，我们通过switchMap切换到一个由当前延迟值生成的timer流——timer(delay)会在指定毫秒后发出一个值，触发repeatWhen重新订阅源请求。因为每次都会取delaySubject的最新值，所以只要更新delaySubject，下次重复就会用新的延迟。

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