private void cancelAndCleanup() {
        if (cancelled) {
            return;
        }

        cancelled = true;
        if (upstream != null) {
            upstream.cancel();
        }
        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