turbine

Turbine 是一个专为 kotlinx.coroutines Flow 设计的轻量级测试库，提供简洁的 API 用于断言流发射的元素、完成状态与异常。其核心功能包括 awaitItem()、awaitComplete()、awaitError() 等挂起方法，内置超时机制避免测试挂起，并支持单流 test 扩展及多流 testIn 模式。基于 Channel 封装，与 runTest 协程测试环境良好集成，适用于 Kotlin 协程流逻辑的单元测试和集成验证，尤其适合 Android、后端等使用 Flow 处理异步数据流的场景。