Android中Rx Publisher转Coroutine Flow时openSubscription过时，如何修复？

云上老周

2026-5-8

解决Reactive Publisher转Coroutine Flow时openSubscription()过时的问题

我之前也碰到过这个问题，当时看到过时提示头都大了，后来发现官方早就给了更简洁稳定的替代方案，不用再纠结openSubscription()了。

核心解决方案：用`asFlow()`替代旧的转换链

官方在kotlinx-coroutines-reactive库中提供了专门的asFlow()扩展函数，这是现在推荐的、稳定的将Reactive Publisher转换为Coroutine Flow的方式，完全可以替代你原来的publisher.openSubscription().receiveAsFlow()写法。

具体步骤：

确认依赖配置
首先确保你的项目中引入了正确的协程与Reactive Streams整合依赖（版本请与你项目中的kotlinx-coroutines-core版本保持一致）：
```
// Gradle Kotlin DSL
implementation("org.jetbrains.kotlinx:kotlinx-coroutines-reactive:1.7.3")
```

替换代码
把原来的过时代码直接替换成一行：

// 原来的过时写法
// val flow = publisher.openSubscription().receiveAsFlow()

// 新的推荐写法
val flow = publisher.asFlow()

为什么这个方案更好？

asFlow()是官方针对Reactive Streams规范设计的标准转换API，内部已经妥善处理了订阅的生命周期、背压传递等细节，比手动调用openSubscription()更安全，不容易出现资源泄漏。
它是稳定API，不会再有“实验性/过时”的警告，后续版本也会持续维护。

如果你暂时无法迁移（不推荐）

如果因为项目依赖限制暂时没法升级或切换到asFlow()，可以通过添加注解来消除警告，但这只是临时方案：

@OptIn(ObsoleteCoroutinesApi::class)
fun convertPublisherToFlow(publisher: Publisher<YourType>): Flow<YourType> {
    return publisher.openSubscription().receiveAsFlow()
}

但强烈建议尽早迁移到asFlow()，因为openSubscription()后续会被正式移除。