RxJava2 with Kotlin coroutines

Question

I'm using both in my app. Kotlin Coroutines are used for single interactions, such as a DB or an API call. But also I'm using RxJava Flowable to observe sensor events.

Kotlin Coroutines has dispatches, and RxJava has shedulers. The idea of them is to provide maximally efficient thread pools, which size depends on hardware configuration.

So if I use both simultaneously, I can have, for example, 8 running threads, 4 in Dispatchers.Default and 4 in Shedulers.computation, instead of 4 threads.

So my question is

Is there a way use Kotlin Dispatchers as RxJava shedulers or vise versa?

Or I should define my own executors, and build dispatchers and shedulers from them?

John O'Reilly · Accepted Answer · 2018-11-15 12:11:53Z

3

You can use kotlinx-coroutines-rx2 extension library (https://github.com/Kotlin/kotlinx.coroutines/tree/master/reactive/kotlinx-coroutines-rx2) ....and in particular Scheduler.asCoroutineDispatcher

answered Nov 15, 2018 at 12:11

John O'Reilly

10.4k6 gold badges45 silver badges67 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

RxJava2 with Kotlin coroutines

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related