@Override
                    public void onError(Throwable t) {
                        // End the response stream if the client presents an error.
                        Status status = Status.fromThrowable(t);
                        logger.info("onError:{}", status);
                        responseObserver.onCompleted();
                    }
copy grpc framework
- https://github.com/grpc/grpc-java/blob/master/examples/src/main/java/io/grpc/examples/manualflowcontrol/ManualFlowControlServer.java
agent-module/plugins-it/google-grpc-it/google-grpc-1-8-it/src/test/java/com/navercorp/pinpoint/it/plugin/grpc/HelloWorldStreamServer.java