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

# coroutines

[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.

[Yoav Gross]

1st_flow.kt

[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?

2nd_flow.kt

[Paul Woitaschek]

Don't open a subscription

[Paul Woitaschek]

toFlowable(BackpressureStrategy.LATEST).asFlow()