@Override
            public void onNext(StreamingOutputCallRequest request) {
                if (request.hasResponseStatus()) {
                    dispatcher.cancel();
                    responseObserver.onError(Status.fromCodeValue(request.getResponseStatus().getCode())
                                                   .withDescription(
                                                           request.getResponseStatus().getMessage())
                                                   .asRuntimeException());
                    return;
                }
                dispatcher.enqueue(toChunkQueue(request));
            }
True bi-directional streaming. Processes requests as they come in. Begins streaming results
immediately.
grpc/src/test/java/com/linecorp/armeria/internal/common/grpc/TestServiceImpl.java