单元测试中.timeout()操作符持续返回TimeoutException问题排查

嘿，我之前也碰到过一模一样的问题！把链式调用简化到只剩timeout还失败，那大概率是测试环境或者调度器的问题，给你列几个最常见的排查方向：

1. 测试里用了默认异步调度器，没做替换 #

RxJava很多操作符默认用的是Schedulers.io()或者Schedulers.computation()这类异步调度器，但单元测试环境里，这些异步线程的执行时机不受测试主线程控制——可能测试代码都跑完了，异步线程还没来得及发射数据，timeout自然就触发了。

举个典型的错误例子：

Observable.just("test")
    .delay(100, TimeUnit.MILLISECONDS) // 默认用computation调度器
    .timeout(500, TimeUnit.MILLISECONDS)
    .test()
    .assertNoErrors();

这时候测试很可能失败，因为delay的异步线程还没发射数据，测试就已经结束了。

解决办法很简单：用TestScheduler替换所有异步调度器，要么全局通过RxJavaPlugins设置，要么在操作符里直接指定：

TestScheduler testScheduler = new TestScheduler();
TestObserver<String> observer = Observable.just("test")
    .delay(100, TimeUnit.MILLISECONDS, testScheduler)
    .timeout(500, TimeUnit.MILLISECONDS, testScheduler)
    .test();

testScheduler.advanceTimeBy(200, TimeUnit.MILLISECONDS); // 手动推进时间，让数据发射完成
observer.assertComplete();
observer.assertValue("test");

2. 超时时间设置得太离谱（甚至是0） #

有时候可能手滑把超时时间设成了0，或者设置的时间比数据发射的实际时间还短——哪怕是同步发射的数据，也可能因为测试框架的微小延迟触发超时。

比如这种低级错误：

Observable.just("test")
    .timeout(0, TimeUnit.MILLISECONDS) // 直接触发超时
    .test()
    .assertError(TimeoutException.class);

赶紧检查你的超时时间参数，哪怕是同步发射，也建议设个合理的小值（比如100ms），避免测试环境的波动坑你。

3. 订阅方式不对，没等待数据发射完成 #

如果用了普通的subscribe()而不是TestObserver（或者test()方法），测试代码可能不会阻塞等待结果，直接走完流程，导致timeout还没等到数据就触发了。

比如错误写法：

// 这里不会阻塞，测试主线程直接结束，timeout触发
Observable.just("test")
    .timeout(100, TimeUnit.MILLISECONDS)
    .subscribe(
        result -> System.out.println(result),
        error -> fail("不该超时啊！")
    );

正确的做法是用TestObserver，它会帮你管理等待逻辑：

TestObserver<String> testObserver = Observable.just("test")
    .timeout(100, TimeUnit.MILLISECONDS)
    .test();

testObserver.assertComplete(); // 验证流正常完成
testObserver.assertValue("test"); // 验证收到预期数据

4. 自定义Observable的发射逻辑有问题 #

如果你的Observable是自己写的create()或者自定义源，那可能是你忘记调用onNext()或者onComplete()了——流一直处于等待状态，timeout自然会触发异常。

比如这种坑人的错误：

Observable.create(emitter -> {
    // 这里忘记调用emitter.onNext("test");
    // 也没调用emitter.onComplete();
})
.timeout(100, TimeUnit.MILLISECONDS)
.test()
.assertError(TimeoutException.class);

检查一下你的Observable实现，确保数据正常发射，没有卡在发射逻辑里。

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