Is there a good interop model where you can subscribe to Rx2 Observable & then unsubscribe when ...

# coroutines

[aerb]

Is there a good interop model where you can subscribe to Rx2 Observable & then unsubscribe when the scope is cancelled?

[Dominaezzz]

Have you looked at Flow?

[Adam Powell]

More specifically the Rx extensions that give you Observable.asFlow()

[Zach Klippenstein (he/him) [MOD]]

You can do observable.asFlow().collect { } or observable.openSubscription().consumeEach { }, but the former is potentially more efficient

[aerb]

thank