Hi everyone How could I write the code below with `Flow` ```Observable.create( { emitter...

# coroutines

[sboishtyan]

Hi everyone
How could I write the code below with Flow

Observable.create(
            { emitter ->
                val process: Process = ProcessBuilder(commandAndArgs)
                    .redirectErrorStream(true)
                    .start()

                emitter.setCancellation {
                    process.destroy()
                }
        )

So idea is that I want when someone starts collecting the flow I will create a process and when a client stops collecting I will destroy the process

[ephemient]

channelFlow {
    val process = ...
    invokeOnClose { process.destroy() }
    process.inputStream.reader().useLines { lines ->
        for (line in lines) send(line)
    }
}

[sboishtyan]

thank you