Package io.servicetalk.http.api

Interface StreamingHttpResponse

All Superinterfaces:

HttpMetaData, HttpResponseMetaData

public interface StreamingHttpResponse
extends HttpResponseMetaData

The equivalent of HttpResponse but provides the payload as a Publisher.

Method Summary

Modifier and Type	Method	Description
default StreamingHttpResponse	addCookie(HttpCookiePair cookie)	Adds a cookie.
default StreamingHttpResponse	addCookie(java.lang.CharSequence name, java.lang.CharSequence value)	Adds a cookie with the specified name and value.
default StreamingHttpResponse	addHeader(java.lang.CharSequence name, java.lang.CharSequence value)	Adds a new header with the specified name and value.
default StreamingHttpResponse	addHeaders(HttpHeaders headers)	Adds all header names and values of headers object.
default StreamingHttpResponse	addSetCookie(HttpSetCookie cookie)	Adds a set-cookie.
default StreamingHttpResponse	addSetCookie(java.lang.CharSequence name, java.lang.CharSequence value)	Adds a set-cookie with the specified name and value.
StreamingHttpResponse	encoding(ContentCodec encoding)	The ContentCodec used to encode the payload of a request or a response.
Publisher<java.lang.Object>	messageBody()	Get the message-body which contains the payload body concatenated with the trailer (if present).
Publisher<Buffer>	payloadBody()	Gets the underlying payload as a Publisher of Buffers.
StreamingHttpResponse	payloadBody(Publisher<Buffer> payloadBody)	Returns a StreamingHttpResponse with its underlying payload set to payloadBody.
<T> StreamingHttpResponse	payloadBody(Publisher<T> payloadBody, HttpSerializer<T> serializer)	Returns a StreamingHttpResponse with its underlying payload set to the result of serialization.
default <T> Publisher<T>	payloadBody(HttpDeserializer<T> deserializer)	Gets and deserializes the payload body.
Publisher<java.lang.Object>	payloadBodyAndTrailers()	Deprecated. Use messageBody().
default StreamingHttpResponse	setHeader(java.lang.CharSequence name, java.lang.CharSequence value)	Sets a header with the specified name and value.
default StreamingHttpResponse	setHeaders(HttpHeaders headers)	Clears the current header entries and copies all header entries of the specified headers object.
BlockingStreamingHttpResponse	toBlockingStreamingResponse()	Translates this StreamingHttpResponse to a BlockingStreamingHttpResponse.
Single<HttpResponse>	toResponse()	Translates this StreamingHttpResponse to a HttpResponse.
<T> StreamingHttpResponse	transform(TrailersTransformer<T,Buffer> trailersTransformer)	Returns a StreamingHttpResponse with its underlying payload transformed to Buffers, with access to the trailers.
StreamingHttpResponse	transformMessageBody(java.util.function.UnaryOperator<Publisher<?>> transformer)	Transform the message-body which contains the payload body concatenated with the trailer (if present).
<T> StreamingHttpResponse	transformPayloadBody(java.util.function.Function<Publisher<Buffer>,Publisher<T>> transformer, HttpSerializer<T> serializer)	Returns a StreamingHttpResponse with its underlying payload transformed to the result of serialization.
default <T,R> StreamingHttpResponse	transformPayloadBody(java.util.function.Function<Publisher<T>,Publisher<R>> transformer, HttpDeserializer<T> deserializer, HttpSerializer<R> serializer)	Returns a StreamingHttpResponse with its underlying payload transformed to the result of serialization.
StreamingHttpResponse	transformPayloadBody(java.util.function.UnaryOperator<Publisher<Buffer>> transformer)	Returns a StreamingHttpResponse with its underlying payload transformed to Buffers.
<T> StreamingHttpResponse	transformRaw(TrailersTransformer<T,java.lang.Object> trailersTransformer)	Deprecated. use transform(TrailersTransformer).
StreamingHttpResponse	transformRawPayloadBody(java.util.function.UnaryOperator<Publisher<?>> transformer)	Deprecated. Use transformPayloadBody(UnaryOperator).
StreamingHttpResponse	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.HttpResponseMetaData

status, status

Method Detail

payloadBody

Publisher<Buffer> payloadBody()

Gets the underlying payload as a Publisher of Buffers.

Returns:

A Publisher of Buffers representing the underlying payload body.

payloadBody

default <T> Publisher<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 Publisher.

Returns:

The results of the deserialization operation.

payloadBodyAndTrailers

@Deprecated
Publisher<java.lang.Object> payloadBodyAndTrailers()

Deprecated.

Use messageBody().

Gets a Publisher that combines the raw payload body concatenated with the trailers.

Returns:

a Publisher that combines the raw payload body concatenated with the trailers.

messageBody

Publisher<java.lang.Object> messageBody()

Get the message-body which contains the payload body concatenated with the trailer (if present).

Returns:

a Publisher that represents the message-body which contains the payload body concatenated with the trailer (if present).

payloadBody

StreamingHttpResponse payloadBody(Publisher<Buffer> payloadBody)

Returns a StreamingHttpResponse with its underlying payload set to payloadBody.

A best effort will be made to apply back pressure to the existing Publisher payload body. 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 Publisher payload body.

Parameters:

payloadBody - The new payload body.

Returns:

this

payloadBody

<T> StreamingHttpResponse payloadBody(Publisher<T> payloadBody,
                                      HttpSerializer<T> serializer)

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

A best effort will be made to apply back pressure to the existing Publisher payload body. 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 Publisher payload body.

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> StreamingHttpResponse transformPayloadBody(java.util.function.Function<Publisher<Buffer>,Publisher<T>> transformer,
                                               HttpSerializer<T> serializer)

Returns a StreamingHttpResponse 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 Publisher and returns the new payload body Publisher prior to serialization. It is assumed the existing payload body Publisher will be transformed/consumed or else no more responses may be processed.

serializer - Used to serialize the payload body.

Returns:

this

transformPayloadBody

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

Returns a StreamingHttpResponse 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 Publisher and returns the new payload body Publisher prior to serialization. It is assumed the existing payload body Publisher 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

StreamingHttpResponse transformPayloadBody(java.util.function.UnaryOperator<Publisher<Buffer>> transformer)

Returns a StreamingHttpResponse with its underlying payload transformed to Buffers.

Parameters:

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

Returns:

this

transformRawPayloadBody

@Deprecated
StreamingHttpResponse transformRawPayloadBody(java.util.function.UnaryOperator<Publisher<?>> transformer)

Deprecated.

Use transformPayloadBody(UnaryOperator).

Returns a StreamingHttpResponse with its underlying payload transformed. Note that the raw objects of the underlying Publisher may be exposed. The object types are not guaranteed to be homogeneous.

Parameters:

transformer - Responsible for transforming the payload body.

Returns:

this

transformMessageBody

StreamingHttpResponse transformMessageBody(java.util.function.UnaryOperator<Publisher<?>> transformer)

Transform the message-body which contains the payload body concatenated with the trailer (if present).

The transformation is not expected to change the presence of trailers in the message body. For example behavior is undefined if a HttpHeaders object is inserted to or removed from to the returned Publisher. To add trailers use transform(TrailersTransformer).

Parameters:

transformer - Responsible for transforming the message-body.

Returns:

this.

transform

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

Returns a StreamingHttpResponse 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

transformRaw

@Deprecated
<T> StreamingHttpResponse transformRaw(TrailersTransformer<T,java.lang.Object> trailersTransformer)

Deprecated.

use transform(TrailersTransformer).

Returns a StreamingHttpResponse with its underlying payload transformed to Objects, 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

toResponse

Single<HttpResponse> toResponse()

Translates this StreamingHttpResponse to a HttpResponse.

Returns:

a Single that completes with a HttpResponse representation of this StreamingHttpResponse.

toBlockingStreamingResponse

BlockingStreamingHttpResponse toBlockingStreamingResponse()

Translates this StreamingHttpResponse to a BlockingStreamingHttpResponse.

Returns:

a BlockingStreamingHttpResponse representation of this StreamingHttpResponse.

version

StreamingHttpResponse 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 HttpResponseMetaData

Parameters:

version - the protocol version to set.

Returns:

this.

encoding

StreamingHttpResponse 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

addHeader

default StreamingHttpResponse 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 HttpResponseMetaData

Parameters:

name - the name of the header.

value - the value of the header.

Returns:

this.

addHeaders

default StreamingHttpResponse 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 HttpResponseMetaData

Parameters:

headers - the headers to add.

Returns:

this.

setHeader

default StreamingHttpResponse 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 HttpResponseMetaData

Parameters:

name - the name of the header.

value - the value of the header.

Returns:

this.

setHeaders

default StreamingHttpResponse 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 HttpResponseMetaData

Parameters:

headers - the headers object which contains new values.

Returns:

this.

addCookie

default StreamingHttpResponse 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 HttpResponseMetaData

Parameters:

cookie - the cookie to add.

Returns:

this.

addCookie

default StreamingHttpResponse 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 HttpResponseMetaData

Parameters:

name - the name of the cookie.

value - the value of the cookie.

Returns:

this.

addSetCookie

default StreamingHttpResponse 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 HttpResponseMetaData

Parameters:

cookie - the cookie to add.

Returns:

this.

addSetCookie

default StreamingHttpResponse 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 HttpResponseMetaData

Parameters:

name - the name of the cookie.

value - the value of the cookie.

Returns:

this.