try to fix flacky test

whyoleg · whyoleg · commit dfb7f7bbd06b · 2020-11-25T23:38:08.000+03:00
diff --git a/rsocket-core/src/commonTest/kotlin/io/rsocket/kotlin/internal/RSocketRequesterTest.kt b/rsocket-core/src/commonTest/kotlin/io/rsocket/kotlin/internal/RSocketRequesterTest.kt
@@ -296,15 +296,18 @@ class RSocketRequesterTest : TestWithConnection(), TestWithLeakCheck {
 
     private fun streamIsTerminatedOnConnectionClose(request: suspend () -> Unit) = test {
         connection.launch {
+            delay(200)
             connection.test {
                 expectFrame { assertTrue(it is RequestFrame) }
                 connection.job.cancel()
-                expectNoEventsIn(200)
+                expectComplete()
             }
         }
         assertFailsWith(CancellationException::class) { request() }
 
         assertFailsWith(CancellationException::class) { request() }
+
+        delay(200)
     }
 
     @Test

Original file line number	Diff line number	Diff line change
`@@ -296,15 +296,18 @@ class RSocketRequesterTest : TestWithConnection(), TestWithLeakCheck {`
`296`	`296`
`297`	`297`	`private fun streamIsTerminatedOnConnectionClose(request: suspend () -> Unit) = test {`
`298`	`298`	`connection.launch {`
	`299`	`+ delay(200)`
`299`	`300`	`connection.test {`
`300`	`301`	`expectFrame { assertTrue(it is RequestFrame) }`
`301`	`302`	`connection.job.cancel()`
`302`		`- expectNoEventsIn(200)`
	`303`	`+ expectComplete()`
`303`	`304`	`}`
`304`	`305`	`}`
`305`	`306`	`assertFailsWith(CancellationException::class) { request() }`
`306`	`307`
`307`	`308`	`assertFailsWith(CancellationException::class) { request() }`
	`309`	`+`
	`310`	`+ delay(200)`
`308`	`311`	`}`
`309`	`312`
`310`	`313`	`@Test`