How to collect a coroutine flow in java?

user_6533301 0
Viewed 3286

I'm developing an Android library,

When the user receives a push notification it may contain deep links, that I need to return to the app.

I did in kotlin with no problem.

This is the function that is called when it needs to send the deep links

fun getDeepLinkFlow(): Flow<HashMap<String, String>?> = flow {
    emit(deepLinks)
}

And in my kotlin test app I managed to use with no problems as well, using like this.

GlobalScope.launch(coroutineContext) {
    SDK.getDeepLinkFlow().collect { deepLinks ->
        println(deepLinks)
    }
}

But now, there's a RN project that whant to use the lib, in order to do that we are doing a RN module that joins the iOS code and the Android code. But it uses java.

So, how can I use the collect from Coroutines on a Java code? or what could I do differently?

kotlin-coroutines kotlin coroutine android java
2 Answers

Coroutines/Flow is inherently awkward to use from Java since it relies on transformed suspend code to work.

One possible solution is to expose an alternative way of consuming the Flow to your java code. Using the RxJava integration library you can expose a compatible Flowable that the java side can consume.

user_14520940

I've decided to change the way deep links were used and start using the ViewModel with a liveData instead.

user_65333010
Related