class StreamingHttpPayloadHolder implements PayloadInfo {

    Publisher<Buffer> payloadBody() {
        if (payloadBody == null) {
            return empty();
        }
        splitTrailersIfRequired();
        return payloadInfo.onlyEmitsBuffer() ? bufferPayload() :
                rawPayload().liftSync(HttpTransportBufferFilterOperator.INSTANCE);
    }

      StreamingHttpPayloadHolder(final HttpHeaders headers, final BufferAllocator allocator,
                               @Nullable final Publisher<?> payloadBody, final DefaultPayloadInfo payloadInfo,
                               final HttpHeadersFactory headersFactory, final HttpProtocolVersion version);

}