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

Class SyncResponseHandlerAdapter<T>

java.lang.Object

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

Type Parameters:

T - Type that the response handler produces.

All Implemented Interfaces:

SdkHttpResponseHandler<T>

public final class SyncResponseHandlerAdapter<T>
extends Object
implements SdkHttpResponseHandler<T>

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

Constructor Summary

Constructors

Constructor and Description
SyncResponseHandlerAdapter(HttpResponseHandler<T> responseHandler, Function<SdkHttpFullResponse,HttpResponse> httpResponseAdapter, ExecutionAttributes executionAttributes)

Method Summary

Modifier and Type	Method and Description
T	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

SyncResponseHandlerAdapter

public SyncResponseHandlerAdapter(HttpResponseHandler<T> responseHandler,
                                  Function<SdkHttpFullResponse,HttpResponse> httpResponseAdapter,
                                  ExecutionAttributes executionAttributes)

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

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

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

Parameters:

throwable - the exception that occurred.

complete

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

Returns:

Transformed result.