Fix race in tests

qwwdfsad · qwwdfsad · commit e28ff2e61033 · 2019-05-27T22:08:58.000+03:00
diff --git a/kotlinx-coroutines-core/jvm/test/flow/CallbackFlowTest.kt b/kotlinx-coroutines-core/jvm/test/flow/CallbackFlowTest.kt
@@ -41,7 +41,7 @@ class CallbackFlowTest : TestBase() {
 
         val flow = channelFlow<Int>(16) {
             api.start(channel)
-            channel.invokeOnClose {
+            awaitClose {
                 api.stop()
             }
         }
@@ -85,7 +85,7 @@ class CallbackFlowTest : TestBase() {
 
         val flow = channelFlow<Int> {
             api.start(channel)
-            channel.invokeOnClose {
+            awaitClose {
                 api.stop()
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -41,7 +41,7 @@ class CallbackFlowTest : TestBase() {`
`41`	`41`
`42`	`42`	`val flow = channelFlow<Int>(16) {`
`43`	`43`	`api.start(channel)`
`44`		`- channel.invokeOnClose {`
	`44`	`+ awaitClose {`
`45`	`45`	`api.stop()`
`46`	`46`	`}`
`47`	`47`	`}`
`@@ -85,7 +85,7 @@ class CallbackFlowTest : TestBase() {`
`85`	`85`
`86`	`86`	`val flow = channelFlow<Int> {`
`87`	`87`	`api.start(channel)`
`88`		`- channel.invokeOnClose {`
	`88`	`+ awaitClose {`
`89`	`89`	`api.stop()`
`90`	`90`	`}`
`91`	`91`	`}`