filter

fun <T> ParallelFlow<T>.filter(predicate: suspend (T) -> Boolean): ParallelFlow<T>
Content copied to clipboard

Filters the values of the upstream in parallel.