Searched refs:flattenConcat (Results 1 – 5 of 5) sorted by relevance
12 …ride fun <T> Flow<T>.flatMap(mapper: suspend (T) -> Flow<T>): Flow<T> = map(mapper).flattenConcat() in <lambda>()23 }.flattenConcat() in <lambda>()50 assertFailsWith<CancellationException>(flow.flattenConcat()) in <lambda>()
47 map(transform).flattenConcat() in <lambda>()82 public fun <T> Flow<Flow<T>>.flattenConcat(): Flow<T> = flow { in <lambda>() method141 return if (concurrency == 1) flattenConcat() else ChannelFlowMerge(this, concurrency) in merge()
87 val toBeMaxed = { word: String -> flowOf(first3(word), last3(word)).flattenConcat() } in <lambda>()105 ).flattenConcat().reduce { a, b -> a + b }) in <lambda>()
1063 …public static final fun flattenConcat (Lkotlinx/coroutines/flow/Flow;)Lkotlinx/coroutines/flow/Flo…
821 …* `flatMap`, `merge` and `concatenate` are replaced with `flattenConcat`, `flattenMerge`, `flatMap…