Skip to content

Commit 290537e

Browse files
committed
Delete constantly flaky test.
1 parent 1a7d220 commit 290537e

File tree

1 file changed

+0
-35
lines changed

1 file changed

+0
-35
lines changed

stub/src/test/java/io/grpc/kotlin/ClientCallsTest.kt

Lines changed: 0 additions & 35 deletions
Original file line numberDiff line numberDiff line change
@@ -661,39 +661,4 @@ class ClientCallsTest: AbstractCallsTest() {
661661
assertThat(responses.single()).isEqualTo(helloReply("Hello, Sunstone"))
662662
assertThat(requestsEvaluations.get()).isEqualTo(2)
663663
}
664-
665-
@ExperimentalCoroutinesApi
666-
@Test
667-
fun bidiStreamingCancelResponsesCancelsRequests() = runBlocking {
668-
val serverImpl = object : GreeterGrpc.GreeterImplBase() {
669-
override fun bidiStreamSayHello(
670-
responseObserver: StreamObserver<HelloReply>
671-
): StreamObserver<HelloRequest> {
672-
return object : StreamObserver<HelloRequest> {
673-
override fun onNext(value: HelloRequest) {
674-
responseObserver.onNext(helloReply("Hello, ${value.name}"))
675-
}
676-
677-
override fun onError(t: Throwable) = throw t
678-
679-
override fun onCompleted() {
680-
responseObserver.onCompleted()
681-
}
682-
}
683-
}
684-
}
685-
686-
val channel = makeChannel(serverImpl)
687-
688-
val cancelled = Job()
689-
val requests = flow {
690-
emit(helloRequest("Steven"))
691-
emit(helloRequest("Garnet"))
692-
suspendUntilCancelled { cancelled.complete() }
693-
}
694-
assertThat(
695-
ClientCalls.bidiStreamingRpc(channel, bidiStreamingSayHelloMethod, requests).take(2).toList()
696-
).containsExactly(helloReply("Hello, Steven"), helloReply("Hello, Garnet")).inOrder()
697-
cancelled.join()
698-
}
699664
}

0 commit comments

Comments
 (0)