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

Class AsyncStreamingResponseHandler<OutputT extends SdkResponse,ReturnT>

java.lang.Object

software.amazon.awssdk.core.internal.http.async.AsyncStreamingResponseHandler<OutputT,ReturnT>

All Implemented Interfaces:

TransformingAsyncResponseHandler<ReturnT>, SdkAsyncHttpResponseHandler

@SdkInternalApi
public final class AsyncStreamingResponseHandler<OutputT extends SdkResponse,ReturnT>
extends Object
implements TransformingAsyncResponseHandler<ReturnT>

Response handler for asynchronous streaming operations.

Constructor Summary

Constructors

Constructor	Description
AsyncStreamingResponseHandler(AsyncResponseTransformer<OutputT,ReturnT> asyncResponseTransformer)

Method Summary

Modifier and Type	Method	Description
void	onError(Throwable error)
void	onHeaders(SdkHttpResponse response)
void	onStream(org.reactivestreams.Publisher<ByteBuffer> publisher)
CompletableFuture<ReturnT>	prepare()	Return the future holding the transformed response.
void	responseHandler(HttpResponseHandler<OutputT> responseHandler)

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncStreamingResponseHandler

public AsyncStreamingResponseHandler(AsyncResponseTransformer<OutputT,ReturnT> asyncResponseTransformer)

Method Details

responseHandler

public void responseHandler(HttpResponseHandler<OutputT> responseHandler)

onHeaders

public void onHeaders(SdkHttpResponse response)

Specified by:

onHeaders in interface SdkAsyncHttpResponseHandler

onStream

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

Specified by:

onStream in interface SdkAsyncHttpResponseHandler

onError

public void onError(Throwable error)

Specified by:

onError in interface SdkAsyncHttpResponseHandler

prepare

public CompletableFuture<ReturnT> 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<OutputT extends SdkResponse>

Returns:

The future holding the transformed response.