I have the following code ```protected suspend fun stdout(message: String, emit: suspend (WfResult...

# coroutines

[Luis Munoz]

I have the following code

protected suspend fun stdout(message: String, emit: suspend (WfResult) -> Unit) {
    emit(WfResult.Stdout(message))
}

protected suspend fun stderr(message: String, emit: suspend (WfResult) -> Unit) {
    emit(WfResult.Stderr(message))
}

open fun main() : Flow<Any>  = flow {
   stdout("someString" , ::emit)
 }

How do I make my own flow so I can use it like this (or how do I extend flow to add more methods):

open fun main() : Flow<Any>  = myFlow {

   stdout("someString")
   stderr("someString")
 }

[araqnid]

Make a subinterface of FlowCollector that includes stdout and stderr methods, and then write myFlow to take an extension method on it that delegates to an underlying flow’s emit methods

[molikuner]

You could also do sth. like this:

suspend fun FlowCollector<WfResult>.stderr(message: String) {
    stderr(message, ::emit)
}

suspend fun FlowCollector<WfResult>.stdout(message: String) {
    stdout(message, ::emit)
}

[Luis Munoz]

thank you, way easier than I thought