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.

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?

Because channels are eager, they subscribe immediately

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

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