close streaming rpc while closing consumer

Author: daleiz

client/src/main/java/io/hstream/impl/ConsumerImpl.java

@@ -148,6 +148,9 @@ public void doStop() {
 
     new Thread(
             () -> {
+              // close the bidistreaming rpc
+              requestStream.onCompleted();
+
               executorService.shutdown();
               logger.info("run shutdown done");
               try {