Is there some kind of `blockingProduce`? I have an...

# coroutines

[aaverin]

Is there some kind of blockingProduce? I have an async callback that I want to wrap into a channel

[deviant]

why you need blocking? just use ordinary produce

[aaverin]

it closes before my callback sends any data

[Dominaezzz]

How many times is your callback called by the async function?

[Dominaezzz]

Once or n times?

[deviant]

it closes before my callback sends any data

just make a loop with suspension point inside

[aaverin]

I have 3rd party library that would deliver data in async manner into a callback any time data changes in the database

[aaverin]

So I need a channel that would deliver me those updates forever while app is running

[Dominaezzz]

I don't think produce should be used then. In a new function just create a channel and send to the channel inside your callback, then return the channel.

[aaverin]

produce is the producing part of the channel, isnt’ it?

[aaverin]

something that only sends, but doesn’t receive

[Dominaezzz]

Yes but it won't help you here.

[Dominaezzz]

Since your function is non-blocking but not suspending.

[aaverin]

should I use suspendCoroutine that would publish into a channel?

[Dominaezzz]

I was just thinking about that but if you use suspendCoroutine, you can only call the Continuation once, as supposed to multiple times, which is what you need.

[Dominaezzz]

fun magicAsync(): ReceiveChannel<Item> {
        val ch = Channel(...)
        magic(..., { it -> ch.send(it) })
        return ch
}

[aaverin]

Yes, looks like it’s the only way

[aaverin]

I’ll try applying it, thanks