We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c12f753 commit 6fd2e34Copy full SHA for 6fd2e34
rsocket-core/src/commonTest/kotlin/io/rsocket/kotlin/internal/RSocketRequesterTest.kt
@@ -411,11 +411,10 @@ class RSocketRequesterTest : TestWithConnection() {
411
fun cancelRequesterToCloseConnection() = test {
412
val request = requester.requestStream(Payload.Empty).produceIn(GlobalScope)
413
connection.test {
414
- awaitFrame { frame ->
415
- assertTrue(frame is RequestFrame)
416
- }
+ awaitFrame { assertIs<RequestFrame>(it) }
417
requester.cancel() //cancel requester
418
- awaitFrame { assertTrue(it is ErrorFrame) }
+ awaitFrame { assertIs<CancelFrame>(it) } // cancelled stream
+ awaitFrame { assertIs<ErrorFrame>(it) } // error on connection
419
awaitError()
420
}
421
delay(100)
0 commit comments