@Override
        public void onError(Throwable cause) {
            requireNonNull(cause, "cause");
            if (cancelled) {
                return;
            }

            if (!(cause instanceof AbortedStreamException)) {
                decoder.processOnError(cause);
            }

            abort(cause);
            cleanup();
        }
Returns a new {@link DecodedStreamMessage} with the specified {@link HttpDecoder},
{@link ByteBufAllocator} and {@code byteBufConverter}.
core/src/main/java/com/linecorp/armeria/internal/common/stream/DecodedStreamMessage.java