update tests

marcoferrer · Aug 22, 2019 · 9bfb977 · 9bfb977
1 parent 19c0ce4
commit 9bfb977
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 3 deletions.
diff --git a/...test/kotlin/com/github/marcoferrer/krotoplus/coroutines/integration/BidiStreamingTests.kt b/...test/kotlin/com/github/marcoferrer/krotoplus/coroutines/integration/BidiStreamingTests.kt
@@ -119,7 +119,7 @@ class BidiStreamingTests {
 
                 val reqChanSpy = spyk(requestChannel)
                 launch(Dispatchers.Default, start = CoroutineStart.UNDISPATCHED) {
-                    assertFailsWithStatus(Status.CANCELLED, "CANCELLED: Call has been cancelled") {
+                    assertFailsWithStatus(Status.CANCELLED) {
                         repeat(6) {
                             reqChanSpy.send { name = "name $it" }
                         }

diff --git a/...kotlin/com/github/marcoferrer/krotoplus/coroutines/server/ServerCallBidiStreamingTests.kt b/...kotlin/com/github/marcoferrer/krotoplus/coroutines/server/ServerCallBidiStreamingTests.kt
@@ -452,7 +452,7 @@ class ServerCallBidiStreamingTests {
 
             val respChannel = deferredRespChannel.await()
             assert(respChannel.isClosedForSend){ "Abandoned response channel should be closed" }
-            verify(exactly = 1) { responseObserver.onError(matchStatus(Status.CANCELLED, "CANCELLED: test")) }
+            verify(exactly = 1) { responseObserver.onError(matchStatus(Status.CANCELLED)) }
             coVerify(exactly = 0) { respChannel.send(any()) }
             assert(serverCtx[Job]!!.isCompleted){ "Server job should be completed" }
             assert(serverCtx[Job]!!.isCancelled){ "Server job should be cancelled" }

diff --git a/...tlin/com/github/marcoferrer/krotoplus/coroutines/server/ServerCallClientStreamingTests.kt b/...tlin/com/github/marcoferrer/krotoplus/coroutines/server/ServerCallClientStreamingTests.kt
@@ -302,7 +302,7 @@ class ServerCallClientStreamingTests {
             // We wait for the server scope to complete before proceeding with assertions
             serverCtx[Job]!!.join()
 
-            verify(exactly = 1) { responseObserver.onError(matchStatus(Status.CANCELLED, "CANCELLED: test")) }
+            verify(exactly = 1) { responseObserver.onError(matchStatus(Status.CANCELLED)) }
 
             assert(serverCtx[Job]!!.isCompleted) { "Server job should be completed" }
             assert(serverCtx[Job]!!.isCancelled) { "Server job should be cancelled" }

diff --git a/...rc/test/kotlin/com/github/marcoferrer/krotoplus/coroutines/server/ServerCallUnaryTests.kt b/...rc/test/kotlin/com/github/marcoferrer/krotoplus/coroutines/server/ServerCallUnaryTests.kt
@@ -160,6 +160,7 @@ class ServerCallUnaryTests {
         verify(exactly = 1) {
             responseObserver.onError(matchStatus(Status.CANCELLED))
         }
+        runBlocking { serverSpy.job?.join() }
         assertEquals("Job was cancelled",serverSpy.error?.message)
     }