@Override
    protected void onCancellation(Subscriber<? super HttpObject> subscriber) {
        try {
            final HttpData lastData = closeRequestDecoder();
            if (lastData != null) {
                lastData.close();
            }
        } catch (ContentTooLargeException cause) {
            // Just warn the cause since a stream is being cancelled.
            logger.warn("A request content exceeds the maximum allowed request length. headers: {}",
                        headers(), cause);
        }
    }
A {@link FilteredHttpRequest} that applies HTTP decoding to {@link HttpObject}s as they are published.
core/src/main/java/com/linecorp/armeria/server/encoding/HttpDecodedRequest.java