Package io.servicetalk.http.api

Interface BlockingStreamingHttpRequest

All Superinterfaces:

HttpMetaData, HttpRequestMetaData

public interface BlockingStreamingHttpRequest
extends HttpRequestMetaData

The equivalent of HttpRequest but provides the payload as a BlockingIterable.

Method Summary

Modifier and Type	Method	Description
default BlockingStreamingHttpRequest	addCookie(HttpCookiePair cookie)	Adds a cookie.
default BlockingStreamingHttpRequest	addCookie(java.lang.CharSequence name, java.lang.CharSequence value)	Adds a cookie with the specified name and value.
default BlockingStreamingHttpRequest	addHeader(java.lang.CharSequence name, java.lang.CharSequence value)	Adds a new header with the specified name and value.
default BlockingStreamingHttpRequest	addHeaders(HttpHeaders headers)	Adds all header names and values of headers object.
BlockingStreamingHttpRequest	addQueryParameter(java.lang.String key, java.lang.String value)	Adds a new query parameter with the specified key and value, which will be percent-encoded if needed.
BlockingStreamingHttpRequest	addQueryParameters(java.lang.String key, java.lang.Iterable<java.lang.String> values)	Adds new query parameters with the specified key and values.
BlockingStreamingHttpRequest	addQueryParameters(java.lang.String key, java.lang.String... values)	Adds new query parameters with the specified key and values.
default BlockingStreamingHttpRequest	addSetCookie(HttpSetCookie cookie)	Adds a set-cookie.
default BlockingStreamingHttpRequest	addSetCookie(java.lang.CharSequence name, java.lang.CharSequence value)	Adds a set-cookie with the specified name and value.
BlockingStreamingHttpRequest	appendPathSegments(java.lang.String... segments)	Appends segments to the current HttpRequestMetaData.path(), performing encoding of each segment (including ('/') characters) according to percent-encoding.
BlockingStreamingHttpRequest	encoding(ContentCodec encoding)	The ContentCodec used to encode the payload of a request or a response.
BlockingStreamingHttpRequest	method(HttpRequestMethod method)	Set the HttpRequestMethod of this StreamingHttpRequest.
BlockingStreamingHttpRequest	path(java.lang.String path)	Sets the path, performing encoding according to percent-encoding, except for forward-slash ('/') characters.
BlockingIterable<Buffer>	payloadBody()	Gets the underlying payload as a Publisher of Buffers.
BlockingStreamingHttpRequest	payloadBody(CloseableIterable<Buffer> payloadBody)	Returns a BlockingStreamingHttpRequest with its underlying payload set to payloadBody.
<T> BlockingStreamingHttpRequest	payloadBody(CloseableIterable<T> payloadBody, HttpSerializer<T> serializer)	Returns a BlockingStreamingHttpRequest with its underlying payload set to the result of serialization.
default <T> BlockingIterable<T>	payloadBody(HttpDeserializer<T> deserializer)	Gets and deserializes the payload body.
BlockingStreamingHttpRequest	payloadBody(java.io.InputStream payloadBody)	Returns a BlockingStreamingHttpRequest with its underlying payload set to payloadBody.
BlockingStreamingHttpRequest	payloadBody(java.lang.Iterable<Buffer> payloadBody)	Returns a BlockingStreamingHttpRequest with its underlying payload set to payloadBody.
<T> BlockingStreamingHttpRequest	payloadBody(java.lang.Iterable<T> payloadBody, HttpSerializer<T> serializer)	Returns a BlockingStreamingHttpRequest with its underlying payload set to the result of serialization.
default java.io.InputStream	payloadBodyInputStream()	Gets the underlying payload as a InputStream.
BlockingStreamingHttpRequest	query(java.lang.String query)	Sets the path, performing encoding according to rfc3986, Query.
BlockingStreamingHttpRequest	rawPath(java.lang.String path)	Sets the path to path, without any encoding performed.
BlockingStreamingHttpRequest	rawQuery(java.lang.String query)	Sets the query component to query, without any encoding performed.
BlockingStreamingHttpRequest	requestTarget(java.lang.String requestTarget)	Set the request-target.
BlockingStreamingHttpRequest	requestTarget(java.lang.String requestTarget, java.nio.charset.Charset encoding)	Set the request-target.
default BlockingStreamingHttpRequest	setHeader(java.lang.CharSequence name, java.lang.CharSequence value)	Sets a header with the specified name and value.
default BlockingStreamingHttpRequest	setHeaders(HttpHeaders headers)	Clears the current header entries and copies all header entries of the specified headers object.
BlockingStreamingHttpRequest	setQueryParameter(java.lang.String key, java.lang.String value)	Sets a query parameter with the specified key and value, which will be percent-encoded if needed.
BlockingStreamingHttpRequest	setQueryParameters(java.lang.String key, java.lang.Iterable<java.lang.String> values)	Sets new query parameters with the specified key and values.
BlockingStreamingHttpRequest	setQueryParameters(java.lang.String key, java.lang.String... values)	Sets new query parameters with the specified key and values.
Single<HttpRequest>	toRequest()	Translates this BlockingStreamingHttpRequest to a HttpRequest.
StreamingHttpRequest	toStreamingRequest()	Translates this BlockingStreamingHttpRequest to a StreamingHttpRequest.
<T> BlockingStreamingHttpRequest	transform(TrailersTransformer<T,Buffer> trailersTransformer)	Returns a BlockingStreamingHttpRequest with its underlying payload transformed to Buffers, with access to the trailers.
<T> BlockingStreamingHttpRequest	transformPayloadBody(java.util.function.Function<BlockingIterable<Buffer>,BlockingIterable<T>> transformer, HttpSerializer<T> serializer)	Returns a BlockingStreamingHttpRequest with its underlying payload transformed to the result of serialization.
default <T,R> BlockingStreamingHttpRequest	transformPayloadBody(java.util.function.Function<BlockingIterable<T>,BlockingIterable<R>> transformer, HttpDeserializer<T> deserializer, HttpSerializer<R> serializer)	Returns a BlockingStreamingHttpRequest with its underlying payload transformed to the result of serialization.
BlockingStreamingHttpRequest	transformPayloadBody(java.util.function.UnaryOperator<BlockingIterable<Buffer>> transformer)	Returns a BlockingStreamingHttpRequest with its underlying payload transformed to Buffers.
BlockingStreamingHttpRequest	version(HttpProtocolVersion version)	Set the protocol version of this HttpMetaData.

Methods inherited from interface io.servicetalk.http.api.HttpMetaData

encoding, headers, toString, toString, version

Methods inherited from interface io.servicetalk.http.api.HttpRequestMetaData

effectiveHostAndPort, hasQueryParameter, hasQueryParameter, host, method, path, port, query, queryParameter, queryParameters, queryParameters, queryParametersIterator, queryParametersKeys, queryParametersSize, rawPath, rawQuery, removeQueryParameters, removeQueryParameters, requestTarget, requestTarget, scheme, userInfo

Method Detail

payloadBody

BlockingIterable<Buffer> payloadBody()

Gets the underlying payload as a Publisher of Buffers.

Returns:

The Publisher of Buffer representation of the underlying payload body.

payloadBodyInputStream

default java.io.InputStream payloadBodyInputStream()

Gets the underlying payload as a InputStream.

Returns:

The InputStream representation of the underlying payload body.

payloadBody

default <T> BlockingIterable<T> payloadBody(HttpDeserializer<T> deserializer)

Gets and deserializes the payload body.

Type Parameters:

T - The resulting type of the deserialization operation.

Parameters:

deserializer - The function that deserializes the underlying BlockingIterable.

Returns:

The results of the deserialization operation.

payloadBody

BlockingStreamingHttpRequest payloadBody(java.lang.Iterable<Buffer> payloadBody)

Returns a BlockingStreamingHttpRequest with its underlying payload set to payloadBody.

A best effort will be made to apply back pressure to the existing payload body which is being replaced. If this default policy is not sufficient you can use transformPayloadBody(UnaryOperator) for more fine grain control.

This method reserves the right to delay completion/consumption of payloadBody. This may occur due to the combination with the existing payload body that is being replaced.

Parameters:

payloadBody - The new payload body.

Returns:

this

payloadBody

BlockingStreamingHttpRequest payloadBody(CloseableIterable<Buffer> payloadBody)

Returns a BlockingStreamingHttpRequest with its underlying payload set to payloadBody.

A best effort will be made to apply back pressure to the existing payload body which is being replaced. If this default policy is not sufficient you can use transformPayloadBody(UnaryOperator) for more fine grain control.

This method reserves the right to delay completion/consumption of payloadBody. This may occur due to the combination with the existing payload body that is being replaced.

Parameters:

payloadBody - The new payload body.

Returns:

this

payloadBody

BlockingStreamingHttpRequest payloadBody(java.io.InputStream payloadBody)

Returns a BlockingStreamingHttpRequest with its underlying payload set to payloadBody.

A best effort will be made to apply back pressure to the existing payload body which is being replaced. If this default policy is not sufficient you can use transformPayloadBody(UnaryOperator) for more fine grain control.

This method reserves the right to delay completion/consumption of payloadBody. This may occur due to the combination with the existing payload body that is being replaced.

Parameters:

payloadBody - The new payload body.

Returns:

this

payloadBody

<T> BlockingStreamingHttpRequest payloadBody(java.lang.Iterable<T> payloadBody,
                                             HttpSerializer<T> serializer)

Returns a BlockingStreamingHttpRequest with its underlying payload set to the result of serialization.

A best effort will be made to apply back pressure to the existing payload body which is being replaced. If this default policy is not sufficient you can use transformPayloadBody(Function, HttpSerializer) for more fine grain control.

This method reserves the right to delay completion/consumption of payloadBody. This may occur due to the combination with the existing payload body that is being replaced.

Type Parameters:

T - The type of objects to serialize.

Parameters:

payloadBody - The new payload body, prior to serialization.

serializer - Used to serialize the payload body.

Returns:

this

payloadBody

<T> BlockingStreamingHttpRequest payloadBody(CloseableIterable<T> payloadBody,
                                             HttpSerializer<T> serializer)

Returns a BlockingStreamingHttpRequest with its underlying payload set to the result of serialization.

A best effort will be made to apply back pressure to the existing payload body which is being replaced. If this default policy is not sufficient you can use transformPayloadBody(Function, HttpSerializer) for more fine grain control.

This method reserves the right to delay completion/consumption of payloadBody. This may occur due to the combination with the existing payload body that is being replaced.

Type Parameters:

T - The type of objects to serialize.

Parameters:

payloadBody - The new payload body, prior to serialization.

serializer - Used to serialize the payload body.

Returns:

this

transformPayloadBody

<T> BlockingStreamingHttpRequest transformPayloadBody(java.util.function.Function<BlockingIterable<Buffer>,BlockingIterable<T>> transformer,
                                                      HttpSerializer<T> serializer)

Returns a BlockingStreamingHttpRequest with its underlying payload transformed to the result of serialization.

Type Parameters:

T - The type of objects to serialize.

Parameters:

transformer - A Function which take as a parameter the existing payload body BlockingIterable and returns the new payload body BlockingIterable prior to serialization. It is assumed the existing payload body BlockingIterable will be transformed/consumed or else no more requests may be processed.

serializer - Used to serialize the payload body.

Returns:

this

transformPayloadBody

default <T,R> BlockingStreamingHttpRequest transformPayloadBody(java.util.function.Function<BlockingIterable<T>,BlockingIterable<R>> transformer,
                                                                      HttpDeserializer<T> deserializer,
                                                                      HttpSerializer<R> serializer)

Returns a BlockingStreamingHttpRequest with its underlying payload transformed to the result of serialization.

Type Parameters:

T - The type of objects to deserialize.

R - The type of objects to serialize.

Parameters:

transformer - A Function which take as a parameter the existing payload body BlockingIterable and returns the new payload body BlockingIterable prior to serialization. It is assumed the existing payload body BlockingIterable will be transformed/consumed or else no more requests may be processed.

deserializer - Used to deserialize the existing payload body.

serializer - Used to serialize the payload body.

Returns:

this

transformPayloadBody

BlockingStreamingHttpRequest transformPayloadBody(java.util.function.UnaryOperator<BlockingIterable<Buffer>> transformer)

Returns a BlockingStreamingHttpRequest with its underlying payload transformed to Buffers.

Parameters:

transformer - A Function which take as a parameter the existing payload body BlockingIterable and returns the new payload body BlockingIterable. It is assumed the existing payload body BlockingIterable will be transformed/consumed or else no more requests may be processed.

Returns:

this

transform

<T> BlockingStreamingHttpRequest transform(TrailersTransformer<T,Buffer> trailersTransformer)

Returns a BlockingStreamingHttpRequest with its underlying payload transformed to Buffers, with access to the trailers.

Type Parameters:

T - The type of state used during the transformation.

Parameters:

trailersTransformer - TrailersTransformer to use for this transform.

Returns:

this

toRequest

Single<HttpRequest> toRequest()

Translates this BlockingStreamingHttpRequest to a HttpRequest.

Returns:

a Single that completes with a HttpRequest representation of this BlockingStreamingHttpRequest.

toStreamingRequest

StreamingHttpRequest toStreamingRequest()

Translates this BlockingStreamingHttpRequest to a StreamingHttpRequest.

Returns:

a StreamingHttpRequest representation of this BlockingStreamingHttpRequest.

rawPath

BlockingStreamingHttpRequest rawPath(java.lang.String path)

Description copied from interface: HttpRequestMetaData

Sets the path to path, without any encoding performed. This assumes that any characters that require encoding have been encoded according to percent-encoding by the caller.

Because this modifies the request target, this may result in the clearing of internal caches. See HttpRequestMetaData.requestTarget(String).

Specified by:

rawPath in interface HttpRequestMetaData

Parameters:

path - the encoded path to set.

Returns:

this.

path

BlockingStreamingHttpRequest path(java.lang.String path)

Description copied from interface: HttpRequestMetaData

Sets the path, performing encoding according to percent-encoding, except for forward-slash ('/') characters. This allows for path("/abc") without it turning into '%2Fabc'.

Specified by:

path in interface HttpRequestMetaData

Parameters:

path - the un-encoded path to set.

Returns:

this.

appendPathSegments

BlockingStreamingHttpRequest appendPathSegments(java.lang.String... segments)

Description copied from interface: HttpRequestMetaData

Appends segments to the current HttpRequestMetaData.path(), performing encoding of each segment (including ('/') characters) according to percent-encoding. A / is used to separate each segment and between the current HttpRequestMetaData.path() and the following segments.

Specified by:

appendPathSegments in interface HttpRequestMetaData

Parameters:

segments - the un-encoded path to set.

Returns:

this.

rawQuery

BlockingStreamingHttpRequest rawQuery(@Nullable
                                      java.lang.String query)

Description copied from interface: HttpRequestMetaData

Sets the query component to query, without any encoding performed. This assumes that any characters that require encoding have been encoded according to percent-encoding by the caller.

Because this modifies the request target, this may result in the clearing of internal caches. See HttpRequestMetaData.requestTarget(String).

Specified by:

rawQuery in interface HttpRequestMetaData

Parameters:

query - the encoded query to set. null will clear the query value (e.g. no ? present in HttpRequestMetaData.requestTarget().

Returns:

this.

query

BlockingStreamingHttpRequest query(@Nullable
                                   java.lang.String query)

Description copied from interface: HttpRequestMetaData

Sets the path, performing encoding according to rfc3986, Query.

Specified by:

query in interface HttpRequestMetaData

Parameters:

query - the un-encoded query to set. null will clear the query value (e.g. no ? present in HttpRequestMetaData.requestTarget().

Returns:

this.

addQueryParameter

BlockingStreamingHttpRequest addQueryParameter(java.lang.String key,
                                               java.lang.String value)

Description copied from interface: HttpRequestMetaData

Adds a new query parameter with the specified key and value, which will be percent-encoded if needed.

Specified by:

addQueryParameter in interface HttpRequestMetaData

Parameters:

key - the query parameter key.

value - the query parameter value.

Returns:

this.

addQueryParameters

BlockingStreamingHttpRequest addQueryParameters(java.lang.String key,
                                                java.lang.Iterable<java.lang.String> values)

Description copied from interface: HttpRequestMetaData

Adds new query parameters with the specified key and values. This method is semantically equivalent to:

 for (T value : values) {
     addQueryParameter(key, value);
 }
 

Specified by:

addQueryParameters in interface HttpRequestMetaData

Parameters:

key - the query parameter key.

values - the query parameter values.

Returns:

this.

addQueryParameters

BlockingStreamingHttpRequest addQueryParameters(java.lang.String key,
                                                java.lang.String... values)

Description copied from interface: HttpRequestMetaData

Adds new query parameters with the specified key and values. This method is semantically equivalent to:

 for (T value : values) {
     query.addQueryParameter(key, value);
 }
 

Specified by:

addQueryParameters in interface HttpRequestMetaData

Parameters:

key - the query parameter key.

values - the query parameter values.

Returns:

this.

setQueryParameter

BlockingStreamingHttpRequest setQueryParameter(java.lang.String key,
                                               java.lang.String value)

Description copied from interface: HttpRequestMetaData

Sets a query parameter with the specified key and value, which will be percent-encoded if needed. Any existing query parameters with the same key are overwritten.

Specified by:

setQueryParameter in interface HttpRequestMetaData

Parameters:

key - the query parameter key.

value - the query parameter value.

Returns:

this.

setQueryParameters

BlockingStreamingHttpRequest setQueryParameters(java.lang.String key,
                                                java.lang.Iterable<java.lang.String> values)

Description copied from interface: HttpRequestMetaData

Sets new query parameters with the specified key and values. This method is equivalent to:

 removeQueryParameter(key);
 for (T value : values) {
     query.addQueryParameter(key, value);
 }
 

Specified by:

setQueryParameters in interface HttpRequestMetaData

Parameters:

key - the query parameter key.

values - the query parameter values.

Returns:

this.

setQueryParameters

BlockingStreamingHttpRequest setQueryParameters(java.lang.String key,
                                                java.lang.String... values)

Description copied from interface: HttpRequestMetaData

Sets new query parameters with the specified key and values. This method is equivalent to:

 removeQueryParameter(key);
 for (T value : values) {
     query.addQueryParameter(key, value);
 }
 

Specified by:

setQueryParameters in interface HttpRequestMetaData

Parameters:

key - the query parameter key.

values - the query parameter values.

Returns:

this.

version

BlockingStreamingHttpRequest version(HttpProtocolVersion version)

Description copied from interface: HttpMetaData

Set the protocol version of this HttpMetaData.

Specified by:

version in interface HttpMetaData

Specified by:

version in interface HttpRequestMetaData

Parameters:

version - the protocol version to set.

Returns:

this.

encoding

BlockingStreamingHttpRequest encoding(ContentCodec encoding)

Description copied from interface: HttpMetaData

The ContentCodec used to encode the payload of a request or a response. If the endpoint is setup with ContentCodingHttpServiceFilter, the server will auto-establish the accepted encoding for the response, unless the caller provides a specific encoding by calling this method. Any encoding passed here, takes precedence. In other words, a compressed response, can be disabled by passing ContentCodings.identity().

Specified by:

encoding in interface HttpMetaData

Parameters:

encoding - The ContentCodec used for the encoding of the payload.

Returns:

this.

See Also:

Content-Encoding

method

BlockingStreamingHttpRequest method(HttpRequestMethod method)

Description copied from interface: HttpRequestMetaData

Set the HttpRequestMethod of this StreamingHttpRequest.

Specified by:

method in interface HttpRequestMetaData

Parameters:

method - the HttpRequestMethod to set.

Returns:

this.

requestTarget

BlockingStreamingHttpRequest requestTarget(java.lang.String requestTarget)

Description copied from interface: HttpRequestMetaData

Set the request-target.

This will be treated as encoded according to percent-encoding.

This may result in clearing of internal caches used by methods that are derived from the request-target, such as HttpRequestMetaData.path(), HttpRequestMetaData.rawQuery(), etc.

Specified by:

requestTarget in interface HttpRequestMetaData

Parameters:

requestTarget - the percent-encoded request-target to set.

Returns:

this.

requestTarget

BlockingStreamingHttpRequest requestTarget(java.lang.String requestTarget,
                                           java.nio.charset.Charset encoding)

Description copied from interface: HttpRequestMetaData

Set the request-target.

This may result in clearing of internal caches used by methods that are derived from the request-target, such as HttpRequestMetaData.path(), HttpRequestMetaData.rawQuery(), etc.

Specified by:

requestTarget in interface HttpRequestMetaData

Parameters:

requestTarget - the request-target to set.

encoding - the Charset to use to encode requestTarget before setting the value.

Returns:

this.

addHeader

default BlockingStreamingHttpRequest addHeader(java.lang.CharSequence name,
                                               java.lang.CharSequence value)

Description copied from interface: HttpMetaData

Adds a new header with the specified name and value.

Specified by:

addHeader in interface HttpMetaData

Specified by:

addHeader in interface HttpRequestMetaData

Parameters:

name - the name of the header.

value - the value of the header.

Returns:

this.

addHeaders

default BlockingStreamingHttpRequest addHeaders(HttpHeaders headers)

Description copied from interface: HttpMetaData

Adds all header names and values of headers object.

Specified by:

addHeaders in interface HttpMetaData

Specified by:

addHeaders in interface HttpRequestMetaData

Parameters:

headers - the headers to add.

Returns:

this.

setHeader

default BlockingStreamingHttpRequest setHeader(java.lang.CharSequence name,
                                               java.lang.CharSequence value)

Description copied from interface: HttpMetaData

Sets a header with the specified name and value. Any existing headers with the same name are overwritten.

Specified by:

setHeader in interface HttpMetaData

Specified by:

setHeader in interface HttpRequestMetaData

Parameters:

name - the name of the header.

value - the value of the header.

Returns:

this.

setHeaders

default BlockingStreamingHttpRequest setHeaders(HttpHeaders headers)

Description copied from interface: HttpMetaData

Clears the current header entries and copies all header entries of the specified headers object.

Specified by:

setHeaders in interface HttpMetaData

Specified by:

setHeaders in interface HttpRequestMetaData

Parameters:

headers - the headers object which contains new values.

Returns:

this.

addCookie

default BlockingStreamingHttpRequest addCookie(HttpCookiePair cookie)

Description copied from interface: HttpMetaData

Adds a cookie.

This may result in multiple HttpCookiePairs with same name.

Specified by:

addCookie in interface HttpMetaData

Specified by:

addCookie in interface HttpRequestMetaData

Parameters:

cookie - the cookie to add.

Returns:

this.

addCookie

default BlockingStreamingHttpRequest addCookie(java.lang.CharSequence name,
                                               java.lang.CharSequence value)

Description copied from interface: HttpMetaData

Adds a cookie with the specified name and value.

This may result in multiple HttpSetCookies with same name. Added cookie will not be wrapped, not secure, and not HTTP-only, with no path, domain, expire date and maximum age.

Specified by:

addCookie in interface HttpMetaData

Specified by:

addCookie in interface HttpRequestMetaData

Parameters:

name - the name of the cookie.

value - the value of the cookie.

Returns:

this.

addSetCookie

default BlockingStreamingHttpRequest addSetCookie(HttpSetCookie cookie)

Description copied from interface: HttpMetaData

Adds a set-cookie.

This may result in multiple HttpSetCookies with same name.

Specified by:

addSetCookie in interface HttpMetaData

Specified by:

addSetCookie in interface HttpRequestMetaData

Parameters:

cookie - the cookie to add.

Returns:

this.

addSetCookie

default BlockingStreamingHttpRequest addSetCookie(java.lang.CharSequence name,
                                                  java.lang.CharSequence value)

Description copied from interface: HttpMetaData

Adds a set-cookie with the specified name and value.

This may result in multiple HttpSetCookies with same name. Added cookie will not be wrapped, not secure, and not HTTP-only, with no path, domain, expire date and maximum age.

Specified by:

addSetCookie in interface HttpMetaData

Specified by:

addSetCookie in interface HttpRequestMetaData

Parameters:

name - the name of the cookie.

value - the value of the cookie.

Returns:

this.