update tests

marcoferrer · Aug 22, 2019 · 70c20ce · 70c20ce
1 parent 19c0ce4
commit 70c20ce
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
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/...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)
     }