Can anyone shed some light on how you use coroutines in addi

Question

Can anyone shed some light on how you use coroutines in addition to RxJava Specifically how you use suspending functions instead of Single Maybe Completable I understand that for one offs that works nicely but what if you want to use that as part of your stream Thanks

gildor · Answer

Good time to ask this question See <https kotlinlang slack com archives C1CFAFJSK p1554384321111300>

gildor · Answer

In general I m not sure that understand your question suspend functions perfectly replace Single Maybe Completable For streams you need something different like just released Flow or Channels

tseisel · Answer

Conceptually you can replace `Single` by suspend functions that return a non null object `Maybe` by suspend functions that return a nullable object `Completable` by suspend functions that return `Unit` Since yesterday you can play with the preview of the new `Flow` API that is intended to replace usages of `Observable` and `Flowable` in the long run

tseisel · Answer

If you have an existing Rx chain that needs to call suspending functions you can call suspend functions by wrapping them in `runBlocking` ``` mySingle map element gt runBlocking suspendingTransform element ```

Fredrik Larsen · Answer

Thanks for the input I use both the rx types and suspending functions independently I was more curious of how people who use rx chains interop with suspending functions Do you prefer to map using runBlocking or still rely on completable maybe single As far as I can see you re losing the error handling if you do that

gildor · Answer

Depends on case mostly use Rx coroutines adapter

gildor · Answer

because blocking is actually bad strategy in many cases you loose cancellation and async Maybe you have particular example where you would like to discuss how combine Observable with suspend function

gildor · Answer

gt As far as I can see you re losing the error handling if you do that No you do not loose actually in this case if `suspendingTransform` will throw exception map will catch it and propagate downstream very similar to what you have with `flatMap`

streetsofboston · Answer

I ll be giving a talk about exactly this question < Fredrik Larsen> at DroidCon Boston next Tuesday

Fredrik Larsen · Answer

Thank you for the input < gildor> < streetsofboston> cool I hope it ll be available online wink

streetsofboston · Answer

It will be available after the conference

Fredrik Larsen · Answer

That s great slightly smiling face Good luck I m looking forward to seeing it

streetsofboston · Answer

<https www droidcon boston com speakers > and look for Anton Spaans

streetsofboston · Answer

But for short like < gildor> said you can use the Rx and Reactive adapters from JB