What’s more idiomatic:

fun events(channel: SendChannel<Event>)
fun events(scope: CoroutineScope): ReceiveChannel<Event>

In my case I need to add a listener when calling

events

and remove it when the channel is closed

Have you considered a https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.channels/-broadcast-channel/ ?

I don’t have multiple consumers and I need the caller to be the one to close the channel

Then using https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.channels/-broadcast-channel/open-subscription.html as your

events

function.

Oh, I’ll try that.

But to answer your actual question, I think the second one is more idiomatic. 🙂

Hmm, I don’t really think BroadcastChannel would fit my use case because I need a clear open and close event

Makes sense.

It’s really strange though, my producer is closed instantly and I can’t figure out why:

override fun events(scope: CoroutineScope): ReceiveChannel<Unit> =
        scope.produce(capacity = Channel.CONFLATED) {
            val listener = { offer(Unit) }
            addListener(listener)
            invokeOnClose { removeListener(listener) }
        }

Oh, I don't think you need the

produce

.

The reason why I need it is because it will be closed when the scope’s job is cancelled

Hmm, there's a way to register a callback with the scope's context to handle closing but I don't know how atm.

Well I don’t want the caller to have to worry about closing the channel

This is a common problem indeed, where the channel is closed when the

produce

coroutine completes, when that is not the intention. Here is a potential workaround:

produce {
    // your stuff, done with procuding ...
    suspendCoroutineCancellable<Unit> { cont ->
        channel.invokeOnClose { cont.resume(Unit) }
    }   
}

Oh right, of course. The coroutine completes. What would be the best way to have this behavior then?

well, there are 2 options for you, the one above or to manually close the channel when the scope is cancelled.

Yeah, I’m trying to bridge a callback API

I see