@Override
        public StreamObserver<StreamingInputCallRequest> streamingInputCall(
                StreamObserver<StreamingInputCallResponse> responseObserver) {
            return new StreamObserver<StreamingInputCallRequest>() {

                @Override
                public void onNext(StreamingInputCallRequest value) {
                    responseObserver.onError(new IllegalArgumentException());
                }

                @Override
                public void onError(Throwable t) {}

                @Override
                public void onCompleted() {}
            };
        }
Constructs a controller using the given executor for scheduling response stream chunks.
grpc/src/test/java/com/linecorp/armeria/server/grpc/GrpcServiceLogTest.java