[grpc-io] Re: GRPC-Java Client did not receive all the message from Server Stream

Maybe sending 20_000_000L messages takes longer than 1min. Then finishLatch.await(1, TimeUnit.MINUTES); would return and shutdown your client. -- Informatikgesellschaft für Software-Entwicklung mbH Schönebergstraße 15 52068 Aachen Telefon : +49 (0) 241 96888-0 Fax : +49 (0) 241 968

[grpc-io] Re: Grpc-java - simulating disconnect from a streaming response api

Maybe you could do something like this: CancellableContext context = Context.current().withCancellation(); context.run(() -> stub.doStream(StreamRequest.getDefaultInstance(), new TestStreamObserver())); ... context.cancel(io.grpc.Status.ABORTED.asException()); -- Informatikgesellschaft für So