com.ibm.cos.v2.core.internal.http.async

Class CombinedResponseAsyncHttpResponseHandler<OutputT>

java.lang.Object

com.ibm.cos.v2.core.internal.http.async.CombinedResponseAsyncHttpResponseHandler<OutputT>

All Implemented Interfaces:

TransformingAsyncResponseHandler<Response<OutputT>>, SdkAsyncHttpResponseHandler

public final class CombinedResponseAsyncHttpResponseHandler<OutputT>
extends Object
implements TransformingAsyncResponseHandler<Response<OutputT>>

Detects whether the response succeeded or failed by just checking the HTTP status and delegates to appropriate async response handler. Can be used with streaming or non-streaming requests.

Constructor Summary

Constructors

Constructor and Description
CombinedResponseAsyncHttpResponseHandler(TransformingAsyncResponseHandler<OutputT> successResponseHandler, TransformingAsyncResponseHandler<? extends SdkException> errorResponseHandler)

Method Summary

Modifier and Type	Method and Description
void	onError(Throwable error) 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<Response<OutputT>>	prepare() Return the future holding the transformed response.

Methods inherited from class java.lang.Object

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

Constructor Detail

CombinedResponseAsyncHttpResponseHandler

public CombinedResponseAsyncHttpResponseHandler(TransformingAsyncResponseHandler<OutputT> successResponseHandler,
                                                TransformingAsyncResponseHandler<? extends SdkException> errorResponseHandler)

Method Detail

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.

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.

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.

prepare

public CompletableFuture<Response<OutputT>> 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(com.ibm.cos.v2.http.SdkHttpResponse) is signaled.

Specified by:

prepare in interface TransformingAsyncResponseHandler<Response<OutputT>>

Returns:

The future holding the transformed response.