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 and Description
StatelessTrailersTransformer()

Method Summary

Modifier and Type	Method and Description
Payload	accept(java.lang.Object __, Payload payload) Accepts a Payload.
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 Payload instances are accepted and the payload stream has terminated with an error.
java.lang.Object	newState() Creates a new instance of the State.
protected HttpHeaders	payloadComplete(HttpHeaders trailers) Same as payloadComplete(Object, HttpHeaders) but without the state.
HttpHeaders	payloadComplete(java.lang.Object __, HttpHeaders trailers) Invoked once all Payload 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 State.

Specified by:

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

Returns:

A new instance of the State.

accept

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

Description copied from interface: TrailersTransformer

Accepts a Payload.

Specified by:

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

Parameters:

__ - State instance created previously by this transformer.

payload - Payload to accept.

Returns:

Potentially transformed Payload instance.

payloadComplete

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

Description copied from interface: TrailersTransformer

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

Specified by:

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

Parameters:

__ - State 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 Payload 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:

__ - State 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 - Payload to accept.

Returns:

Potentially transformed Payload 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