@Override
    public void streamingOutputCall(StreamingOutputCallRequest request,
                                    StreamObserver<StreamingOutputCallResponse> responseObserver) {
        // Create and start the response dispatcher.
        new ResponseDispatcher(responseObserver).enqueue(toChunkQueue(request)).completeInput();
    }
Given a request that specifies chunk size and interval between responses, creates and schedules
the response stream.
grpc/src/test/java/com/linecorp/armeria/internal/common/grpc/TestServiceImpl.java