software.amazon.awssdk.core.http.async

Class UnmarshallingAsyncResponseHandler<ResponseT,ReturnT>

java.lang.Object

software.amazon.awssdk.core.http.async.UnmarshallingAsyncResponseHandler<ResponseT,ReturnT>

Type Parameters:

ResponseT - Response POJO type.

ReturnT - Transformation result type. Returned by complete()

All Implemented Interfaces:

SdkHttpResponseHandler<ReturnT>

public class UnmarshallingAsyncResponseHandler<ResponseT,ReturnT>
extends Object
implements SdkHttpResponseHandler<ReturnT>

Adapts an AsyncResponseTransformer to a SdkHttpResponseHandler by first performing unmarshalling on the initial response (headers/status code).

Constructor Summary

Constructors

Constructor and Description
UnmarshallingAsyncResponseHandler(AsyncResponseTransformer<ResponseT,ReturnT> asyncResponseTransformer, FunctionalUtils.UnsafeFunction<SdkHttpResponse,ResponseT> unmarshaller)

Method Summary

Modifier and Type	Method and Description
ReturnT	complete() Called when all parts of the response have been received.
void	exceptionOccurred(Throwable throwable) Called when an exception occurs during the request/response.
void	headersReceived(SdkHttpResponse response) Called when the initial response with headers is received.
void	onStream(org.reactivestreams.Publisher<ByteBuffer> publisher) Called when the HTTP client is ready to start sending data to the response handler.

Methods inherited from class java.lang.Object

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

Constructor Detail

UnmarshallingAsyncResponseHandler

public UnmarshallingAsyncResponseHandler(AsyncResponseTransformer<ResponseT,ReturnT> asyncResponseTransformer,
                                         FunctionalUtils.UnsafeFunction<SdkHttpResponse,ResponseT> unmarshaller)

Parameters:

asyncResponseTransformer - Response handler being adapted.

unmarshaller - Unmarshaller that takes an SdkHttpResponse and returns the unmarshalled POJO.

Method Detail

headersReceived

public void headersReceived(SdkHttpResponse response)

Description copied from interface: SdkHttpResponseHandler

Called when the initial response with headers is received.

Specified by:

headersReceived in interface SdkHttpResponseHandler<ReturnT>

Parameters:

response - the SdkHttpResponse

onStream

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

Description copied from interface: SdkHttpResponseHandler

Called when the HTTP client is ready to start sending data to the response handler. Implementations must subscribe to the Publisher and request data via a Subscription as they can handle it.

If at any time the subscriber wishes to stop receiving data, it may call Subscription.cancel(). This will be treated as a failure of the response and the SdkHttpResponseHandler.exceptionOccurred(Throwable) callback will be invoked.

Specified by:

onStream in interface SdkHttpResponseHandler<ReturnT>

exceptionOccurred

public void exceptionOccurred(Throwable throwable)

Description copied from interface: SdkHttpResponseHandler

Called when an exception occurs during the request/response. This is a terminal method call, no other method invocations should be expected on the SdkHttpResponseHandler after this point.

Specified by:

exceptionOccurred in interface SdkHttpResponseHandler<ReturnT>

Parameters:

throwable - the exception that occurred.

complete

public ReturnT complete()

Description copied from interface: SdkHttpResponseHandler

Called when all parts of the response have been received. This is a terminal method call, no other method invocations should be expected on the SdkHttpResponseHandler after this point.

Specified by:

complete in interface SdkHttpResponseHandler<ReturnT>

Returns:

Transformed result.