I have state I want to share between

onStart

and

onCompletion

of a

Flow

. (Basically open a resource in

onStart

and close it in

onCompletion

) What's the most idiomatic way besides reinventing the wheel?

But it's how flow works by default, just use

flow {}

block

➕ Do this:

fun <T> Flow<T>.myOperator() = flow {
    try {
         openResource()
         emitAll(this@myOperator)
    } finally {
         closeResource()
    }
}

@elizarov Is it the case when it comes to

channelFlow

?

For callbacks yes, use channelFlow/callbackFlow, but this question not about callbacks, as I understand,

awaitClose

tho of course useful, but actual implementation depends on what is happening after

onStart

Yeah, actually it depends. thanks @gildor