@Override
    public StreamObserver<HelloRequest> bidiHello(StreamObserver<HelloReply> responseObserver) {
        return new StreamObserver<HelloRequest>() {
            @Override
            public void onNext(HelloRequest value) {
                // Respond to every request received.
                responseObserver.onNext(buildReply(toMessage(value.getName())));
            }

            @Override
            public void onError(Throwable t) {
                responseObserver.onError(t);
            }

            @Override
            public void onCompleted() {
                responseObserver.onCompleted();
            }
        };
    }
Sends a {@link HelloReply} when each {@link HelloRequest} is received. The response will be completed
when the request is completed.
armeria-example/armeria-grpc-server/src/main/java/com/example/grpc/armeria/HelloServiceImpl.java