servicetalk-http-api/src/main/java/io/servicetalk/http/api/StreamingHttpRequests.java
/**
     * Creates a new {@link StreamingHttpRequest} which is read from the transport. If the request contains
     * <a href="https://tools.ietf.org/html/rfc7230#section-4.4">trailers</a> then the passed {@code payload}
     * {@link Publisher} should also emit {@link HttpHeaders} before completion.
     *
     * @param method the {@link HttpRequestMethod} of the request.
     * @param requestTarget the <a href="https://tools.ietf.org/html/rfc7230#section-3.1.1">request-target</a> of the
     * request.
     * @param version the {@link HttpProtocolVersion} of the request.
     * @param headers the {@link HttpHeaders} of the request.
     * @param allocator the allocator used for serialization purposes if necessary.
     * @param payload a {@link Publisher} for payload that optionally emits {@link HttpHeaders} if the request contains
     * <a href="https://tools.ietf.org/html/rfc7230#section-4.4">trailers</a>.
     * @param requireTrailerHeader {@code true} if <a href="https://tools.ietf.org/html/rfc7230#section-4.4">Trailer</a>
     * header is required to accept trailers. {@code false} assumes trailers may be present if other criteria allows.
     * @param headersFactory {@link HttpHeadersFactory} to use.
     * @return a new {@link StreamingHttpRequest}.
     */
Creates a new  StreamingHttpRequest which is read from the transport. If the request contains
trailers then the passed  payload
Publisher should also emit  HttpHeaders before completion.

@param method the  HttpRequestMethod of the request.
@param requestTarget the request-target of the
request.
@param version the  HttpProtocolVersion of the request.
@param headers the  HttpHeaders of the request.
@param allocator the allocator used for serialization purposes if necessary.
@param payload a  Publisher for payload that optionally emits  HttpHeaders if the request contains
trailers.
@param requireTrailerHeader  true if Trailer
header is required to accept trailers.  false assumes trailers may be present if other criteria allows.
@param headersFactory  HttpHeadersFactory to use.
@return a new  StreamingHttpRequest.
Creates a new StreamingHttpRequest which is read from the transport . If the request contains trailers then the passed payload Publisher should also emit HttpHeaders before completion . @param method the HttpRequestMethod of the request . @param requestTarget the request - target of the request . @param version the HttpProtocolVersion of the request . @param headers the HttpHeaders of the request . @param allocator the allocator used for serialization purposes if necessary . @param payload a Publisher for payload that optionally emits HttpHeaders if the request contains trailers . @param requireTrailerHeader true if Trailer header is required to accept trailers . false assumes trailers may be present if other criteria allows . @param headersFactory HttpHeadersFactory to use . @return a new StreamingHttpRequest .
public static StreamingHttpRequest newTransportRequest(
            final HttpRequestMethod method, final String requestTarget, final HttpProtocolVersion version,
            final HttpHeaders headers, final BufferAllocator allocator, final Publisher<Object> payload,
            final boolean requireTrailerHeader, final HttpHeadersFactory headersFactory) {
        return new DefaultStreamingHttpRequest(method, requestTarget, version, headers, null, null, allocator, payload,
                forTransportReceive(requireTrailerHeader, version, headers), headersFactory);
    }
public static StreamingHttpRequest newTransportRequest ( final HttpRequestMethod method , final String requestTarget , final HttpProtocolVersion version , final HttpHeaders headers , final BufferAllocator allocator , final Publisher < Object > payload , final boolean requireTrailerHeader , final HttpHeadersFactory headersFactory ) { return new DefaultStreamingHttpRequest ( method , requestTarget , version , headers , null , null , allocator , payload , forTransportReceive ( requireTrailerHeader , version , headers ) , headersFactory ) ; }
Creates a new {@link StreamingHttpRequest} which is read from the transport.
Creates a new { @link StreamingHttpRequest } which is read from the transport .