RxJS异步管道操作符测试：含异步修改函数的Marble测试问询

嘿，这个问题我熟！用Marble测试带异步操作符（比如delay）的RxJS函数，关键在于用虚拟时间替代真实等待，不然每次测试都等1秒太浪费时间了。我给你一步步拆解怎么弄：

核心思路：用TestScheduler管理虚拟时间 #

RxJS自带的TestScheduler是Marble测试的灵魂，它能把所有异步操作（比如delay）转换成同步执行的虚拟时间流程，完全不用真的等延迟结束。

完整测试示例 #

先假设你的modify函数是这样的（不管是旧语法还是pipe新语法，逻辑都通用）：

// 旧语法版本
function modify(source) {
  return source.delay(1000);
}

// 新pipe语法版本（推荐）
function modify(source) {
  return source.pipe(delay(1000));
}

接下来是正确的测试代码：

it("should correctly delay the source emission", function() {
  // 初始化TestScheduler，传入断言函数对比实际和预期结果
  const testScheduler = new Rx.TestScheduler(function(actual, expected) {
    expect(actual).toEqual(expected);
  });

  // 用run方法包裹整个测试逻辑，它会帮你处理虚拟时间上下文
  testScheduler.run(function({ hot, expectObservable }) {
    // 定义数据源的marble和对应的值
    const sourceMarble = "-a|"; // 10ms后发出值'a'，然后流完成
    const values = { a: "test" };

    // 创建热Observable数据源
    const source$ = hot(sourceMarble, values);
    // 调用你要测试的modify函数
    const result$ = modify(source$);

    // 验证结果流：数据源发出'a'后，延迟1000ms再发出'a'并完成
    // 这里用时间标记`1000ms`比写100个'-'更直观
    expectObservable(result$).toBe("1000ms (a|)", values);
  });
});

关键细节说明 #

• 不用手动mock delay：TestScheduler会自动替换RxJS内部的异步调度器，所以你不用去修改Rx.Observable.prototype.delay，它会自动把delay的真实等待转换成虚拟时间推进。
• marble语法的时间对应：默认每个marble字符代表10ms，比如-a是10ms后发出值；如果要对应1000ms的延迟，直接写1000ms比写100个-方便太多。
• 必须用run方法包裹：hot、expectObservable这些方法都依赖TestScheduler的上下文，只有在run的回调里使用才会生效。
• 不要漏了完成标记|：如果你的流是会完成的，一定要在marble里加上|，不然TestScheduler会认为流还在运行，导致断言失败。

额外提示：如果需要自定义时间单位 #

要是你觉得默认10ms/字符不方便，可以在初始化TestScheduler的时候指定时间单位：

const testScheduler = new Rx.TestScheduler(/* 断言函数 */, 1); // 每个字符代表1ms

这样----a|就代表4ms后发出值，不过一般默认的10ms足够用了。

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