transform

fun <T, R> ParallelFlow<T>.transform(callback: suspend FlowCollector<R>.(T) -> Unit): ParallelFlow<R>
Content copied to clipboard

Transform each upstream item into zero or more emits for the downstream in parallel.