RxJava2 与 Kotlin 协程

Question

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

Kotlin Coroutines 有dispatches，RxJava 有shedulers。 它们的想法是提供最大效率的线程池，其大小取决于硬件配置。

因此，如果我同时使用这两个线程，例如，我可以拥有 8 个运行线程，Dispatchers.Default 中的 4 个和Shedulers.computation 中的 4 个，而不是 4 个线程。

所以我的问题是

有没有办法将Kotlin Dispatchers 用作RxJava shedulers 或虎钳 反之亦然？

或者我应该定义自己的executors，并从它们构建dispatchers 和shedulers？

Answer 1

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