单元测试中TestObserver无法接收数据问题求助

我之前踩过这个坑！这种TestObserver收不到数据还超时的报错，大概率是RxJava的线程调度或者测试配置出了问题，咱们一步步来排查：

1. 先排查线程调度问题（最常见原因） #

很多生产代码里会用Schedulers.io()、AndroidSchedulers.mainThread()这类后台调度器，但单元测试环境下，这些线程不会自动被TestObserver等待，导致流在后台跑但测试主线程已经超时了。

解决办法是在测试前替换成同步调度器，比如Schedulers.trampoline()（让任务在当前线程同步执行），测试后记得重置避免影响其他测试：

@Before
public void setupTest() {
    // 替换IO线程调度器
    RxJavaPlugins.setIoSchedulerHandler(scheduler -> Schedulers.trampoline());
    // 如果是Android项目，替换主线程调度器
    RxAndroidPlugins.setMainThreadSchedulerHandler(scheduler -> Schedulers.trampoline());
}

@After
public void teardownTest() {
    // 重置调度器
    RxJavaPlugins.reset();
    RxAndroidPlugins.reset();
}

如果用了TestScheduler（比如测试延迟逻辑），记得调用testScheduler.advanceTimeBy()或者testScheduler.triggerActions()手动触发任务执行。

2. 确认被测试的流真的发射了数据 #

有时候问题出在被测试代码本身：比如流根本没被订阅，或者发射数据的逻辑因为条件判断没走到。

可以先在测试里临时加个普通订阅，看看有没有数据输出：

yourObservable.subscribe(
    value -> System.out.println("Received value: " + value),
    error -> error.printStackTrace()
);

另外检查是否用了defer()、fromCallable()这类延迟创建的操作符，确保它们的逻辑没有被跳过。

3. 调整TestObserver的超时时间 #

默认的TestObserver超时可能太短，尤其是如果你的流有少量延迟逻辑。可以手动设置更长的超时时间：

// 等待至少1个数据，超时时间设为5秒
testObserver.awaitCount(1, 5, TimeUnit.SECONDS)
            .assertValueCount(1);

// 或者等待流终止（完成/错误），设置超时
testObserver.awaitTerminalEvent(5, TimeUnit.SECONDS)
            .assertComplete()
            .assertValueCount(1);

4. 检查是否有未被捕获的错误 #

有时候流里发生了错误，但被某个操作符吞掉了（比如onErrorReturn处理不当，或者订阅时没传错误回调），导致TestObserver既收不到数据也收不到完成信号，最终超时。

可以打印所有错误信息排查：

testObserver.errors().forEach(Throwable::printStackTrace);

同时调用testObserver.assertNoErrors()来确认流没有发生未处理的错误。

5. 确认使用了正确的TestObserver创建方式 #

确保你是通过流的.test()方法创建TestObserver，而不是手动实例化：

// 正确的方式
TestObserver<String> testObserver = yourObservable.test();

// 错误的方式（不要这么做）
TestObserver<String> testObserver = new TestObserver<>();
yourObservable.subscribe(testObserver);

先从线程调度的问题查起，这是最容易踩的坑。如果还是不行，就一步步排查流的发射逻辑、错误处理，应该能找到问题所在。

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