@Override
    protected void beforeComplete(Subscriber<? super HttpObject> subscriber) {
        final HttpData lastData = closeRequestDecoder();
        if (lastData == null) {
            return;
        }
        if (!lastData.isEmpty()) {
            subscriber.onNext(lastData);
        } else {
            lastData.close();
        }
    }
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