Hi, does anyone have had success converting from R...

# android

[Yoav Gross]

Hi, does anyone have had success converting from Rx2 Observable to Kotlin Flow, and getting data?

[Yoav Gross]

This code works in the sense that I can the initial data from the channel, but the observable is dead - it doesn’t send anymore data beyond the initial list.

observable_to_flow

[Yoav Gross]

Now how do I extract the List<> from the flow? collect{} doesn’t compile. Furthermore how do I keep this as a stream of data like Rx2?

observable_to_flow2.txt

[gildor]

Do not use channel for that, instead convert observable to Flowable and use asFlow()

[gildor]

Because channels are eager, they subscribe immediately

[gildor]

For now there is no adapter for Observable, only for Flowable

[Yoav Gross]

Thanks @gildor , how do I consume the flow? I can’t use flow collect

[gildor]

Why do you cannot use it?

[Yoav Gross]

It doesn’t compile

[gildor]

And what is error? Have you import collect extension?

[Yoav Gross]

Screen Shot 2019-09-26 at 16.38.27.png

[gildor]

import kotlinx.coroutines.flow.collect

[gildor]

Alt+Enter on error, it will suggest you to import it automatically

[gildor]

https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/-flow/collect.html

[Yoav Gross]

Nice that helped! Studio didn’t mark it for import for some reason, manual import helped. 💯

[gildor]

I see on your screenshot that studio suggests you import (underlined collect function means that there is some suitable import)