@@ -20,8 +20,8 @@ import kotlinx.coroutines.flow.internal.unsafeFlow as flow
20
20
*
21
21
* It can be demonstrated with the following example:
22
22
* ```
23
- * val flow = flowOf(1, 2).delayEach (10)
24
- * val flow2 = flowOf("a", "b", "c").delayEach (15)
23
+ * val flow = flowOf(1, 2).onEach { delay (10) }
24
+ * val flow2 = flowOf("a", "b", "c").onEach { delay (15) }
25
25
* flow.combine(flow2) { i, s -> i.toString() + s }.collect {
26
26
* println(it) // Will print "1a 2a 2b 2c"
27
27
* }
@@ -42,8 +42,8 @@ public fun <T1, T2, R> Flow<T1>.combine(flow: Flow<T2>, transform: suspend (a: T
42
42
*
43
43
* It can be demonstrated with the following example:
44
44
* ```
45
- * val flow = flowOf(1, 2).delayEach (10)
46
- * val flow2 = flowOf("a", "b", "c").delayEach (15)
45
+ * val flow = flowOf(1, 2).onEach { delay (10) }
46
+ * val flow2 = flowOf("a", "b", "c").onEach { delay (15) }
47
47
* combine(flow, flow2) { i, s -> i.toString() + s }.collect {
48
48
* println(it) // Will print "1a 2a 2b 2c"
49
49
* }
@@ -292,8 +292,8 @@ public inline fun <reified T, R> combineTransform(
292
292
*
293
293
* It can be demonstrated with the following example:
294
294
* ```
295
- * val flow = flowOf(1, 2, 3).delayEach (10)
296
- * val flow2 = flowOf("a", "b", "c", "d").delayEach (15)
295
+ * val flow = flowOf(1, 2, 3).onEach { delay (10) }
296
+ * val flow2 = flowOf("a", "b", "c", "d").onEach { delay (15) }
297
297
* flow.zip(flow2) { i, s -> i.toString() + s }.collect {
298
298
* println(it) // Will print "1a 2b 3c"
299
299
* }
0 commit comments