Package software.amazon.awssdk.core.internal.http.async

Class FilterTransformingAsyncHttpResponseHandler<ResultT>

java.lang.Object

software.amazon.awssdk.core.internal.http.async.FilterTransformingAsyncHttpResponseHandler<ResultT>

All Implemented Interfaces:

TransformingAsyncResponseHandler<ResultT>, SdkAsyncHttpResponseHandler

public abstract class FilterTransformingAsyncHttpResponseHandler<ResultT>
extends Object
implements TransformingAsyncResponseHandler<ResultT>

Decorator class that simply delegates to the wrapped TransformingAsyncResponseHandler. Useful for intercepting the desired callback(s) before passing them on to the delegate.

Constructor Summary

Constructors

Constructor	Description
FilterTransformingAsyncHttpResponseHandler(TransformingAsyncResponseHandler<ResultT> delegate)

Method Summary

Modifier and Type	Method	Description
void	onError(Throwable error)	Called when there is an error making the request or receiving the response.
void	onHeaders(SdkHttpResponse headers)	Called when the headers have been received.
void	onStream(org.reactivestreams.Publisher<ByteBuffer> stream)	Called when the streaming body is ready.
CompletableFuture<ResultT>	prepare()	Return the future holding the transformed response.

Methods inherited from class java.lang.Object

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

Constructor Details

FilterTransformingAsyncHttpResponseHandler

public FilterTransformingAsyncHttpResponseHandler(TransformingAsyncResponseHandler<ResultT> delegate)

Method Details

prepare

public CompletableFuture<ResultT> prepare()

Description copied from interface: TransformingAsyncResponseHandler

Return the future holding the transformed response.

This method is guaranteed to be called before the request is executed, and before SdkAsyncHttpResponseHandler.onHeaders(software.amazon.awssdk.http.SdkHttpResponse) is signaled.

Specified by:

prepare in interface TransformingAsyncResponseHandler<ResultT>

Returns:

The future holding the transformed response.

onHeaders

public void onHeaders(SdkHttpResponse headers)

Description copied from interface: SdkAsyncHttpResponseHandler

Called when the headers have been received.

Specified by:

onHeaders in interface SdkAsyncHttpResponseHandler

Parameters:

headers - The headers.

onStream

public void onStream(org.reactivestreams.Publisher<ByteBuffer> stream)

Description copied from interface: SdkAsyncHttpResponseHandler

Called when the streaming body is ready.

This method is always called. If the response does not have a body, then the publisher will complete the subscription without signalling any elements.

Specified by:

onStream in interface SdkAsyncHttpResponseHandler

Parameters:

stream - The streaming body.

onError

public void onError(Throwable error)

Description copied from interface: SdkAsyncHttpResponseHandler

Called when there is an error making the request or receiving the response. If the error is encountered while streaming the body, then the error is also delivered to the Subscriber.

Specified by:

onError in interface SdkAsyncHttpResponseHandler

Parameters:

error - The error.