@Override
    public void abort(Throwable cause) {
        if (closed) {
            return;
        }

        closeCause = cause;
        closed = true;

        final StreamMessage<StreamMessage<HttpData>> emitter = this.emitter;
        if (emitter != null) {
            emitter.abort(cause);
        }
    }
Reactive processor that encodes a stream of {@link BodyPart}s into an HTTP payload.
core/src/main/java/com/linecorp/armeria/common/multipart/MultipartEncoder.java