A modern programming language that makes developers happier.

kotlinlang

Is there something like this `pipe` function (which I just made up) available in the coroutines library? (Sends emissions from one `Flow` to another `FlowCollector` ) :
```suspend fun &lt;T, U&gt; Flow&lt;T&gt;.pipe(destination: FlowCollector&lt;U&gt;, transform: (T) -&gt; U) {
  collect { 
    destination.emit(transform(it))
  }
}```
It feels so obvious but I’ve been looking at the available extension functions and haven’t spotted it. Thanks!

Isn't this just a combination of `emitAll` and `map`?
```destination.emitAll(
  source.map(transform)
)```

I suppose I could just do that. Thanks for the tip!