Mastering High Performance with Kotlin

Coroutines with reactive programming

You can easily combine your code written in a reactive style with coroutines. For this, you can use the kotlinx-coroutines-rx2 module (https://github.com/Kotlin/kotlinx.coroutines/tree/master/reactive/kotlinx-coroutines-rx2).

This library contains a set of functions to convert coroutines to live collections from RxJava, such as rxMaybe, rxCompletable, rxSingle, rxObservable, and rxFlowable.

Or you can, for instance, invoke an await* family method of a live collection from RxJava. We can use this with our reactiveOrder method:

suspend fun rxToCoroutinesOrder(amountOfCakes: Int): List<Cake> {    return reactiveOrder(amountOfCakes).await()}

We can invoke this method using the following code:

fun main(args: Array<String>) ...