@@ -28,7 +28,7 @@ import kotlinx.coroutines.flow.unsafeFlow as flow
28
28
* }
29
29
* ```
30
30
*/
31
- @ExperimentalCoroutinesApi
31
+ @FlowPreview
32
32
public fun <T1 , T2 , R > Flow<T1>.combineLatest (other : Flow <T2 >, transform : suspend (T1 , T2 ) -> R ): Flow <R > = flow {
33
33
coroutineScope {
34
34
val firstChannel = asFairChannel(this @combineLatest)
@@ -80,7 +80,7 @@ public fun <T1, T2, R> Flow<T1>.combineLatest(other: Flow<T2>, transform: suspen
80
80
* Returns a [Flow] whose values are generated with [transform] function by combining
81
81
* the most recently emitted values by each flow.
82
82
*/
83
- @ExperimentalCoroutinesApi
83
+ @FlowPreview
84
84
public inline fun <T1 , T2 , T3 , R > Flow<T1>.combineLatest (
85
85
other : Flow <T2 >,
86
86
other2 : Flow <T3 >,
@@ -97,7 +97,7 @@ public inline fun <T1, T2, T3, R> Flow<T1>.combineLatest(
97
97
* Returns a [Flow] whose values are generated with [transform] function by combining
98
98
* the most recently emitted values by each flow.
99
99
*/
100
- @ExperimentalCoroutinesApi
100
+ @FlowPreview
101
101
public inline fun <T1 , T2 , T3 , T4 , R > Flow<T1>.combineLatest (
102
102
other : Flow <T2 >,
103
103
other2 : Flow <T3 >,
@@ -116,7 +116,7 @@ public inline fun <T1, T2, T3, T4, R> Flow<T1>.combineLatest(
116
116
* Returns a [Flow] whose values are generated with [transform] function by combining
117
117
* the most recently emitted values by each flow.
118
118
*/
119
- @ExperimentalCoroutinesApi
119
+ @FlowPreview
120
120
public inline fun <T1 , T2 , T3 , T4 , T5 , R > Flow<T1>.combineLatest (
121
121
other : Flow <T2 >,
122
122
other2 : Flow <T3 >,
@@ -137,7 +137,7 @@ public inline fun <T1, T2, T3, T4, T5, R> Flow<T1>.combineLatest(
137
137
* Returns a [Flow] whose values are generated with [transform] function by combining
138
138
* the most recently emitted values by each flow.
139
139
*/
140
- @ExperimentalCoroutinesApi
140
+ @FlowPreview
141
141
public inline fun <reified T , R > Flow<T>.combineLatest (vararg others : Flow <T >, crossinline transform : suspend (Array <T >) -> R ): Flow <R > =
142
142
combineLatest(* others, arrayFactory = { arrayOfNulls(others.size + 1 ) }, transform = { transform(it) })
143
143
0 commit comments