Delete constantly flaky test.

grpc · May 12, 2020 · 290537e · 290537e
1 parent 1a7d220
commit 290537e
Showing 1 changed file with 0 additions and 35 deletions.
diff --git a/stub/src/test/java/io/grpc/kotlin/ClientCallsTest.kt b/stub/src/test/java/io/grpc/kotlin/ClientCallsTest.kt
@@ -661,39 +661,4 @@ class ClientCallsTest: AbstractCallsTest() {
     assertThat(responses.single()).isEqualTo(helloReply("Hello, Sunstone"))
     assertThat(requestsEvaluations.get()).isEqualTo(2)
   }
-
-  @ExperimentalCoroutinesApi
-  @Test
-  fun bidiStreamingCancelResponsesCancelsRequests() = runBlocking {
-    val serverImpl = object : GreeterGrpc.GreeterImplBase() {
-      override fun bidiStreamSayHello(
-        responseObserver: StreamObserver<HelloReply>
-      ): StreamObserver<HelloRequest> {
-        return object : StreamObserver<HelloRequest> {
-          override fun onNext(value: HelloRequest) {
-            responseObserver.onNext(helloReply("Hello, ${value.name}"))
-          }
-
-          override fun onError(t: Throwable) = throw t
-
-          override fun onCompleted() {
-            responseObserver.onCompleted()
-          }
-        }
-      }
-    }
-
-    val channel = makeChannel(serverImpl)
-
-    val cancelled = Job()
-    val requests = flow {
-      emit(helloRequest("Steven"))
-      emit(helloRequest("Garnet"))
-      suspendUntilCancelled { cancelled.complete() }
-    }
-    assertThat(
-      ClientCalls.bidiStreamingRpc(channel, bidiStreamingSayHelloMethod, requests).take(2).toList()
-    ).containsExactly(helloReply("Hello, Steven"), helloReply("Hello, Garnet")).inOrder()
-    cancelled.join()
-  }
 }