Syntax fix to show that FlowCollector invokes action, not that action takes in FlowCollector

pablobaxter · pablobaxter · commit bf30f68f0354 · 2021-04-29T09:35:06.000-07:00
diff --git a/kotlinx-coroutines-core/common/src/flow/operators/Delay.kt b/kotlinx-coroutines-core/common/src/flow/operators/Delay.kt
@@ -469,7 +469,7 @@ private fun <T> Flow<T>.timeoutInternal(
         values.onReceiveOrNull { value ->
             if (value !== DONE) {
                 if (value === TIMEOUT) {
-                    action(downStream)
+                    downStream.action()
                     values.cancel(ChildCancelledException())
                     return@onReceiveOrNull false // Just end the loop here. Nothing more to be done.
                 }

Original file line number	Diff line number	Diff line change
`@@ -469,7 +469,7 @@ private fun <T> Flow<T>.timeoutInternal(`
`469`	`469`	`values.onReceiveOrNull { value ->`
`470`	`470`	`if (value !== DONE) {`
`471`	`471`	`if (value === TIMEOUT) {`
`472`		`- action(downStream)`
	`472`	`+ downStream.action()`
`473`	`473`	`values.cancel(ChildCancelledException())`
`474`	`474`	`return@onReceiveOrNull false // Just end the loop here. Nothing more to be done.`
`475`	`475`	`}`