@@ -48,7 +48,7 @@ import kotlinx.coroutines.launch
4848 * Returns a flow containing the results of applying the given [transform] function.
4949 * Transformations performed parallel with given [concurrency] limit and preserving the order of elements.
5050 */
51- @FlowPreview
51+ @FlowPreview// TODO: related issue https://github.com/Kotlin/kotlinx.coroutines/issues/3938
5252@ExperimentalCoroutinesApi
5353public fun <T , R > Flow<T>.mapEager (
5454 concurrency : Int = DEFAULT_CONCURRENCY ,
@@ -79,7 +79,7 @@ public fun <T, R> Flow<T>.mapEager(
7979 * a positive channel capacity or one of the constants defined in [Channel]. If inner [Flow] tries to emit
8080 * more than [bufferSize] values before being concatenated to output, then it will be suspended
8181 */
82- @FlowPreview
82+ @FlowPreview// TODO: related issue https://github.com/Kotlin/kotlinx.coroutines/issues/3938
8383@ExperimentalCoroutinesApi
8484public fun <T , R > Flow<T>.flatMapConcatEager (
8585 concurrency : Int = DEFAULT_CONCURRENCY ,
@@ -109,7 +109,7 @@ public fun <T, R> Flow<T>.flatMapConcatEager(
109109 * a positive channel capacity or one of the constants defined in [Channel]. If [Flow] tries to emit
110110 * more than [bufferSize] values before being concatenated to output, then it will be suspended
111111 */
112- @FlowPreview
112+ @FlowPreview// TODO: related issue https://github.com/Kotlin/kotlinx.coroutines/issues/3938
113113@ExperimentalCoroutinesApi
114114public fun <T > Flow<Flow<T>>.flattenConcatEager (
115115 concurrency : Int = DEFAULT_CONCURRENCY ,
0 commit comments