@Override
        public void onError(Throwable cause) {
            if (!writer.isOpen()) {
                return;
            }
            writer.close(cause);
        }
A {@link Subscriber} implementation which writes a streaming response with the contents converted from
the objects published from a publisher.
core/src/main/java/com/linecorp/armeria/internal/server/ResponseConversionUtil.java