@Override
        public void onComplete() {
            if (cancelled) {
                return;
            }
            try {
                decoder.processOnComplete(input, DecodedStreamMessage.this);
                close();
            } catch (Exception e) {
                abort(e);
            } finally {
                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