首页 > 解决方案 > RxJava2 与 Kotlin 协程

问题描述

我在我的应用程序中同时使用两者。 Kotlin Coroutines用于单个交互,例如 DB 或 API 调用。但我也RxJava Flowable用来观察传感器事件。

Kotlin CoroutinesdispatchesRxJavashedulers。它们的想法是提供最大效率的线程池,其大小取决于硬件配置。

因此,如果我同时使用两者,例如,我可以拥有 8 个运行线程,4 inDispatchers.Default和 4 in Shedulers.computation,而不是 4 个线程。

所以我的问题是

有没有办法使用Kotlin DispatchersasRxJava shedulers或反之亦然?

或者我应该定义我自己的,并从他们那里executors构建?dispatchersshedulers

标签: androidkotlinrx-java2

解决方案


您可以使用kotlinx-coroutines-rx2扩展库(https://github.com/Kotlin/kotlinx.coroutines/tree/master/reactive/kotlinx-coroutines-rx2) ....特别是Scheduler.asCoroutineDispatcher


推荐阅读