Hello all I got an external API which delivers data via an callback running on a different thread. H...

# coroutines

[bogdoll]

Hello all
I got an external API which delivers data via an callback running on a different thread.
How could I encapsulate those data into flows?

An simple example, given an external API:

fun externalApi(query: String, callback: (Long,String)->Unit): Unit

I would like to convert this into something like

fun externalApiWrapper( query: String ): Flow<Pair<Long,String >>

Currently I have no idea how to do that.

[gildor]

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

[bogdoll]

Thanks, that works for me. 🙂

[gildor]

Just want to check, is this callback called multiple times, so is it stream of events?

[bogdoll]

Yes, the callback will be called multiple times.

[bogdoll]

But I got one more question, regarding the back pressure. If it happens that the producer would be faster, how could modify specify the behavior of the "hidden" channel object? E.g. how could I block the thread of the producer, when I call the offer method. I did not really get the buffer method (mentioned in the comment of the link you provided).

[gildor]

You can change behavior of hidden channel using buffer method, what is exactly not clear? You can just set channel capacity using it

[gildor]

If you want to block the producer's thread, you can wrap send() method with runBlocking

[bogdoll]

Btw, found a nice article: https://medium.com/@elizarov/callbacks-and-kotlin-flows-2b53aa2525cf