Package io.servicetalk.http.api

Class StatelessTrailersTransformer<Payload>

java.lang.Object

io.servicetalk.http.api.StatelessTrailersTransformer<Payload>

Type Parameters:

Payload - Type of payload this transformer receives.

All Implemented Interfaces:

TrailersTransformer<java.lang.Object,Payload>

public class StatelessTrailersTransformer<Payload>
extends java.lang.Object
implements TrailersTransformer<java.lang.Object,Payload>

An implementation of TrailersTransformer that does not require any state.

Constructor Summary

Constructors

Constructor	Description
StatelessTrailersTransformer()

Method Summary

Modifier and Type	Method	Description
Payload	accept(java.lang.Object __, Payload payload)	Accepts a TrailersTransformer.
protected Payload	accept(Payload payload)	Same as accept(Object, Object) but without the state.
HttpHeaders	catchPayloadFailure(java.lang.Object __, java.lang.Throwable cause, HttpHeaders trailers)	Invoked once all TrailersTransformer instances are accepted and the payload stream has terminated with an error.
java.lang.Object	newState()	Creates a new instance of the TrailersTransformer.
protected HttpHeaders	payloadComplete(HttpHeaders trailers)	Same as payloadComplete(Object, HttpHeaders) but without the state.
HttpHeaders	payloadComplete(java.lang.Object __, HttpHeaders trailers)	Invoked once all TrailersTransformer instances are accepted and the payload stream has successfully completed.
protected HttpHeaders	payloadFailed(java.lang.Throwable cause, HttpHeaders trailers)	Same as catchPayloadFailure(Object, Throwable, HttpHeaders) but without the state.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StatelessTrailersTransformer

public StatelessTrailersTransformer()

Method Detail

newState

public final java.lang.Object newState()

Description copied from interface: TrailersTransformer

Creates a new instance of the TrailersTransformer.

Specified by:

newState in interface TrailersTransformer<java.lang.Object,Payload>

Returns:

A new instance of the TrailersTransformer.

accept

public final Payload accept(java.lang.Object __,
                            Payload payload)

Description copied from interface: TrailersTransformer

Accepts a TrailersTransformer.

Specified by:

accept in interface TrailersTransformer<java.lang.Object,Payload>

Parameters:

__ - TrailersTransformer instance created previously by this transformer.

payload - TrailersTransformer to accept.

Returns:

Potentially transformed TrailersTransformer instance.

payloadComplete

public final HttpHeaders payloadComplete(java.lang.Object __,
                                         HttpHeaders trailers)

Description copied from interface: TrailersTransformer

Invoked once all TrailersTransformer instances are accepted and the payload stream has successfully completed.

Specified by:

payloadComplete in interface TrailersTransformer<java.lang.Object,Payload>

Parameters:

__ - TrailersTransformer instance created previously by this transformer.

trailers - Trailer for the streaming HTTP request/response that is transformed.

Returns:

Potentially transformed trailers.

catchPayloadFailure

public final HttpHeaders catchPayloadFailure(java.lang.Object __,
                                             java.lang.Throwable cause,
                                             HttpHeaders trailers)
                                      throws java.lang.Throwable

Description copied from interface: TrailersTransformer

Invoked once all TrailersTransformer instances are accepted and the payload stream has terminated with an error.

This method suppresses the passed cause if it returns successfully. In order to propagate the cause, one should throw the same from this method.

Specified by:

catchPayloadFailure in interface TrailersTransformer<java.lang.Object,Payload>

Parameters:

__ - TrailersTransformer instance created previously by this transformer.

cause - of the payload stream failure.

trailers - Trailer for the streaming HTTP request/response that is transformed.

Returns:

Potentially transformed trailers. This will swallow the passed cause. In order to propagate the cause, it should be re-thrown.

Throws:

java.lang.Throwable - If the error has to be propagated

accept

protected Payload accept(Payload payload)

Same as accept(Object, Object) but without the state.

Parameters:

payload - StatelessTrailersTransformer to accept.

Returns:

Potentially transformed StatelessTrailersTransformer instance.

payloadComplete

protected HttpHeaders payloadComplete(HttpHeaders trailers)

Same as payloadComplete(Object, HttpHeaders) but without the state.

Parameters:

trailers - Trailer for the streaming HTTP request/response that is transformed.

Returns:

Potentially transformed trailers.

payloadFailed

protected HttpHeaders payloadFailed(java.lang.Throwable cause,
                                    HttpHeaders trailers)
                             throws java.lang.Throwable

Same as catchPayloadFailure(Object, Throwable, HttpHeaders) but without the state.

Parameters:

cause - of the payload stream failure.

trailers - Trailer for the streaming HTTP request/response that is transformed.

Returns:

Potentially transformed trailers. This will swallow the passed cause. In order to propagate the cause, it should be re-thrown.

Throws:

java.lang.Throwable - If the error has to be propagated