如何在RxJs 7中复现RxJs 6.x版本的delay操作符行为？

RxJS 7 对 delay 操作符的逻辑做了调整，仅对 next 和 error 两类通知做延迟处理，EMPTY 这类只会发送 complete 通知的 Observable 不会触发延迟逻辑，因此会直接执行 complete 回调。如果需要复现 RxJS 6 中连 complete 通知也会延迟的效果，可使用以下两种方案：

方案1：直接替换原有写法（最轻量） #

使用 timer 搭配 ignoreElements 组合实现完全等价的效果：

import { timer } from 'rxjs';
import { ignoreElements } from 'rxjs/operators';

timer(5000).pipe(
  // 忽略timer发出的0值，仅保留complete通知
  ignoreElements()
).subscribe({
  complete: () => {
    console.log('complete');
  }
});

方案2：封装兼容旧行为的操作符 #

如果项目中大量使用了 EMPTY.pipe(delay(xxx)) 这类写法，不想逐个修改，可以自定义一个兼容 RxJS 6 行为的 delay 操作符：

import { MonoTypeOperatorFunction, timer } from 'rxjs';
import { delay, concatWith, ignoreElements } from 'rxjs/operators';

function legacyDelay<T>(delayMs: number): MonoTypeOperatorFunction<T> {
  return source => source.pipe(
    // 保留原有delay对next、error的延迟逻辑
    delay(delayMs),
    // 拼接延迟后的空流，保证complete通知也会延后对应时长
    concatWith(timer(delayMs).pipe(ignoreElements()))
  );
}

// 用法和原逻辑完全一致，无需修改其他代码
import { EMPTY } from 'rxjs';
EMPTY.pipe(legacyDelay(5000)).subscribe({
  complete: () => {
    console.log('complete');
  }
});

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