是否有RxJS管道操作符可实现‘设置即遗忘’式延迟任务且不影响原流？

你可以在tap操作符内部订阅一个独立的timer流，这样既不用外部subscribe()，也不会阻塞主管道，更不会修改主管道的输出结果。

正确实现代码： #

import { timer, take } from 'rxjs';
import { tap, map } from 'rxjs/operators';

// ...

selectionChanged$ = this.selectionChanged.pipe(
  map(() => this.someValue),
  tap(() => /* 这里执行你的同步操作 */),
  tap(() => {
    // 创建独立的延迟执行流，订阅后立即触发，不影响主管道
    timer(1000).pipe(
      take(1), // 确保timer只执行一次后自动取消订阅，避免内存泄漏
      tap(() => this.doSomething())
    ).subscribe();
  })
);

方案说明： #

• 不使用外部subscribe()：内部的subscribe()属于副作用的一部分，不需要在管道外部额外订阅，符合“设置即遗忘”的要求。
• 无需等待定时器完成：主管道的流不会等待内部的timer流完成，tap只是触发这个副作用，主流会继续向下传递map后的someValue。
• 不修改管道结果：主管道的输出依然是map处理后的this.someValue，内部的timer流完全独立，不会干扰主流的类型和值。

为什么之前的switchMap方案不行？ #

switchMap会把主管道的流替换成doSomething$的流，所以主管道最终会输出timer发射的数值（类型变为number），而且必须等待timer完成才会发射值，完全不符合你的需求。

内容的提问来源于stack exchange，提问作者Get Off My Lawn