Is there something like this `pipe` function (which I just made up) available in the coroutines libr...

# flow

[Chris Fillmore]

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 <T, U> Flow<T>.pipe(destination: FlowCollector<U>, transform: (T) -> 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!

[diesieben07]

Isn't this just a combination of emitAll and map?

destination.emitAll(
  source.map(transform)
)

[Chris Fillmore]

Yes, you’re right.

[Chris Fillmore]

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