本文详解在使用 Room + RxJava 进行数据库单元测试时，因忽略 Completable 订阅导致 AssertionError: Value not present 的根本原因及修复方案。
本文详解在使用 room + rxjava 进行数据库单元测试时，因忽略 completable 订阅导致 `assertionerror: value not present` 的根本原因及修复方案。
在基于 Room 和 RxJava 构建响应式数据层时，一个常见却极易被忽视的陷阱是：调用 Completable 方法（如 upsert()）后未订阅或未触发执行。由于 RxJava 的 Completable 是惰性（lazy）的，它不会在创建时自动执行，而必须显式订阅（或通过操作符链式触发），否则数据库写入操作根本不会发生——这正是你遇到 Value not present 错误的根源。
你的测试代码中：
database.simpleTaskDao().upsert(task); // ❌ 无订阅 → 操作被丢弃！
这一行看似“插入了数据”，实则只是构建了一个未执行的 Completable 对象。后续立即调用 observeAll() 获取数据时，表中仍是空的，因此 firstElement() 发出 Optional.empty()，最终 TestObserver.assertValue(...) 因未收到满足条件的非空列表而失败，并抛出 AssertionError: Value not present（提示：latch=0, values=1, completions=1 —— 即 Observable 已完成但未发出有效值）。
✅ 正确做法是将写入与读取操作通过 RxJava 操作符串联，确保顺序执行且全部触发。推荐使用 andThen()，它专为在 Completable 完成后无缝衔接另一个 Observable/Single/Maybe 而设计：
你接手一个需求时，是不是经常这样："改一个小字段 → 结果把不相关的代码也改了"、"需求说得很模糊 → 做着做着发现跑偏了"、"数据库加个字段 → 上线才发现漏了数据兼容"、"做了个新功能 → 一个月后自己都忘了当时怎么设计的"、"写到一半被中断 → 再回来不知道从哪继续"；这个 Skill 就是专门解决这些问题的。 它会自动探测你的项目环境（JDK、Spring Boot、ORM、数据库、前端框架），记在
立即学习“Java免费学习笔记（深入）”；
@Test
public void insertTaskAndGetTask() {
SimpleTask task = new SimpleTask(34, "title", "description", Calendar.getInstance(), 1, false);
TestObserver<List<SimpleTask>> testObserver = new TestObserver<>();
// ✅ 正确链式调用：upsert 完成后，再执行 observeAll
database.simpleTaskDao()
.upsert(task)
.andThen(database.simpleTaskDao().observeAll())
.firstElement() // 转换为 Maybe<List<SimpleTask>>
.toObservable() // 适配 TestObserver（需 Observable）
.subscribe(testObserver);
testObserver.awaitTerminalEvent(2, TimeUnit.SECONDS); // 建议添加超时，避免死等
testObserver.assertNoErrors();
testObserver.assertValue(list -> list.size() == 1 && list.get(0).getId() == 34);
}⚠️ 关键注意事项：
- 永远不要忽略 Completable / Single / Maybe 的订阅：它们不是“fire-and-forget”，而是“build-and-wait-for-subscribe”；
-
避免
allowMainThreadQueries()在正式测试中的滥用：虽然方便调试，但应配合InstantTaskExecutorRule或TrampolineScheduler实现线程可控，确保测试行为与真实环境一致； -
验证数据一致性：
assertValue中建议不仅校验集合大小，还应检查关键字段（如id,title），防止“空对象占位”类误判； -
清理资源：在
@After方法中调用database.close()，防止内存泄漏（尤其在大量测试用例时）。
总结：RxJava 的响应式链条强调“声明即执行”，而 Room 的异步操作必须被显式驱动。将 upsert() 与 observeAll() 用 andThen() 组合，既保证了操作时序，又符合函数式编程的可组合性原则——这是编写健壮、可测试的 Room+RxJava 数据层的基石实践。
