Searched defs:flatMap (Results 1 – 9 of 9) sorted by relevance
12 …override fun <T> Flow<T>.flatMap(mapper: suspend (T) -> Flow<T>): Flow<T> = flatMapConcat(transfor… in <lambda>() method in kotlinx.coroutines.flow.FlatMapConcatTest
12 …override fun <T> Flow<T>.flatMap(mapper: suspend (T) -> Flow<T>): Flow<T> = map(mapper).flattenCon… in <lambda>() method in kotlinx.coroutines.flow.FlattenConcatTest
12 …override fun <T> Flow<T>.flatMap(mapper: suspend (T) -> Flow<T>): Flow<T> = map(mapper).flattenMer… in <lambda>() method in kotlinx.coroutines.flow.FlattenMergeTest
12 …override fun <T> Flow<T>.flatMap(mapper: suspend (T) -> Flow<T>): Flow<T> = flatMapMerge(transform… in <lambda>() method in kotlinx.coroutines.flow.FlatMapMergeFastPathTest
12 abstract fun <T> Flow<T>.flatMap(mapper: suspend (T) -> Flow<T>): Flow<T> in <lambda>() method in kotlinx.coroutines.flow.FlatMapBaseTest
12 …override fun <T> Flow<T>.flatMap(mapper: suspend (T) -> Flow<T>): Flow<T> = flatMapMerge(transform… in <lambda>() method in kotlinx.coroutines.flow.FlatMapMergeTest
185 public fun <T, R> Flow<T>.flatMap(mapper: suspend (T) -> Flow<R>): Flow<R> = noImpl() in <lambda>() method
300 …default <R> IOStream<R> flatMap(final IOFunction<? super T, ? extends IOStream<? extends R>> mappe… in flatMap() method
316 public fun <E, R> ReceiveChannel<E>.flatMap( in toMutableList() method