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

Class AsyncResponseHandler<T>

java.lang.Object

software.amazon.awssdk.core.internal.http.async.AsyncResponseHandler<T>

Type Parameters:

T - Type that the response handler produces.

All Implemented Interfaces:

TransformingAsyncResponseHandler<T>, SdkAsyncHttpResponseHandler

public final class AsyncResponseHandler<T>
extends Object
implements TransformingAsyncResponseHandler<T>

Response handler for asynchronous non-streaming operations.

Adapts an HttpResponseHandler to the asynchronous TransformingAsyncResponseHandler. Buffers all content into a ByteArrayInputStream then invokes the HttpResponseHandler.handle(software.amazon.awssdk.http.SdkHttpFullResponse, software.amazon.awssdk.core.interceptor.ExecutionAttributes) method.

Constructor Summary

Constructors

Constructor	Description
AsyncResponseHandler(HttpResponseHandler<T> responseHandler, Function<SdkHttpFullResponse,SdkHttpFullResponse> crc32Validator, ExecutionAttributes executionAttributes)

Method Summary

Modifier and Type	Method	Description
void	onError(Throwable err)	Called when there is an error making the request or receiving the response.
void	onHeaders(SdkHttpResponse response)	Called when the headers have been received.
void	onStream(org.reactivestreams.Publisher<ByteBuffer> publisher)	Called when the streaming body is ready.
CompletableFuture<T>	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

AsyncResponseHandler

public AsyncResponseHandler(HttpResponseHandler<T> responseHandler,
 Function<SdkHttpFullResponse,SdkHttpFullResponse> crc32Validator,
 ExecutionAttributes executionAttributes)

Method Details

onHeaders

public void onHeaders(SdkHttpResponse response)

Description copied from interface: SdkAsyncHttpResponseHandler

Called when the headers have been received.

Specified by:

onHeaders in interface SdkAsyncHttpResponseHandler

Parameters:

response - The headers.

onStream

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

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:

publisher - The streaming body.

onError

public void onError(Throwable err)

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:

err - The error.

prepare

public CompletableFuture<T> 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<T>

Returns:

The future holding the transformed response.