private void assertNotFailed() {
            if (failure != null) {
                throw new IllegalStateException("Stream already failed", failure);
            }
        }
Schedules the next response chunk to be dispatched. If all input has been received and there
are no more chunks in the queue, the stream is closed.
grpc/src/test/java/com/linecorp/armeria/internal/common/grpc/TestServiceImpl.java