如何测试RxJava的.delay(20, SECONDS)以立即获取测试结果？

我来帮你搞定这个测试耗时的痛点！对于包含delay(20, SECONDS)这类时间依赖的RxJava代码，TestScheduler绝对是最优解——它是RxJava专门为测试场景打造的虚拟时间调度器，不用等真实时间流逝，就能让你手动操控时间推进，瞬间拿到测试结果。

具体实现步骤： #

1. 创建TestScheduler实例
   先在测试类里初始化一个虚拟调度器：

   TestScheduler testScheduler = new TestScheduler();
   

2. 让delay使用虚拟调度器
   要实现时间控制，得让被测试代码里的delay操作符用上我们的TestScheduler，有两种常用方式：

   • 业务代码可配置调度器（推荐）：在业务逻辑里把调度器作为参数传入，方便测试时替换：

     // 业务代码示例，允许外部传入调度器
     public Observable<String> getDelayedData(Scheduler scheduler) {
         return Observable.just("expected_result")
             .delay(20, SECONDS, scheduler);
     }
     

     测试时直接传入testScheduler：

     Observable<String> testObservable = yourService.getDelayedData(testScheduler);
     

   • 全局替换调度器（适配无法修改业务代码的场景）：用RxJavaPlugins全局替换计算调度器，但务必在测试后重置，避免影响其他测试：

     @Before
     public void setUp() {
         RxJavaPlugins.setComputationSchedulerHandler(s -> testScheduler);
     }
     
     @After
     public void tearDown() {
         RxJavaPlugins.reset();
     }
     

3. 手动推进时间并验证结果
   订阅Observable后，调用TestScheduler的方法快进时间，就能立即触发delay后的逻辑：

   TestObserver<String> testObserver = testObservable.test();
   // 此时时间未到，不会收到事件
   testObserver.assertNoValues();
   
   // 直接快进20秒，跳过真实等待
   testScheduler.advanceTimeBy(20, SECONDS);
   
   // 现在可以验证预期结果了
   testObserver.assertValue("expected_result");
   testObserver.assertComplete();
   

核心优势： #

• 完全省去真实等待时间，测试秒级完成
• 精准控制时间推进幅度，方便测试不同时间节点的场景
• 搭配TestObserver能轻松验证事件序列的正确性

注意事项： #

• 如果用全局替换调度器的方式，测试结束后一定要调用RxJavaPlugins.reset()，否则会干扰其他测试用例的调度器行为
• 优先选择“业务代码可配置调度器”的方案，这种设计更灵活，也符合依赖注入的最佳实践

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