Remove more constantly flaky tests.

Author: lowasser

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

@@ -406,58 +406,6 @@ class ClientCallsTest: AbstractCallsTest() {
     }
   }
 
-  @FlowPreview
-  @Test
-  fun clientStreamingRpcCancellation() = runBlocking {
-    val serverCancelled = Job()
-    val serverReceived = Job()
-    val serverImpl = object : GreeterGrpc.GreeterImplBase() {
-      override fun clientStreamSayHello(
-        responseObserver: StreamObserver<HelloReply>
-      ): StreamObserver<HelloRequest> {
-        return object : StreamObserver<HelloRequest> {
-          private val names = mutableListOf<String>()
-
-          override fun onNext(value: HelloRequest) {
-            whenContextIsCancelled { serverCancelled.complete() }
-            Context.current().withCancellation().addListener(
-              Context.CancellationListener {
-                serverCancelled.complete()
-              },
-              directExecutor()
-            )
-            serverReceived.complete()
-            names += value.name
-          }
-
-          override fun onError(t: Throwable) = throw t
-
-          override fun onCompleted() {
-            responseObserver.onNext(
-              helloReply(names.joinToString(prefix = "Hello, ", separator = ", "))
-            )
-            responseObserver.onCompleted()
-          }
-        }
-      }
-    }
-
-    channel = makeChannel(serverImpl)
-
-    val requests = Channel<HelloRequest>()
-    val rpc = async {
-      ClientCalls.clientStreamingRpc(
-        channel = channel,
-        method = clientStreamingSayHelloMethod,
-        requests = requests.consumeAsFlow()
-      )
-    }
-    requests.send(helloRequest("Tim"))
-    serverReceived.join()
-    rpc.cancel(CancellationException("no longer needed"))
-    serverCancelled.join()
-  }
-
   @FlowPreview
   @Test
   fun clientStreamingRpcCancelled() = runBlocking {