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

Class AsyncAfterTransmissionInterceptorCallingResponseHandler<T>

java.lang.Object

com.ibm.cos.v2.core.internal.http.async.AsyncAfterTransmissionInterceptorCallingResponseHandler<T>

Type Parameters:

T - the type of the result

All Implemented Interfaces:

TransformingAsyncResponseHandler<T>, SdkAsyncHttpResponseHandler

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

Async response handler decorator to run interceptors after response is received.

Constructor Summary

Constructors

Constructor and Description
AsyncAfterTransmissionInterceptorCallingResponseHandler(TransformingAsyncResponseHandler<T> delegate, ExecutionContext context)

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

AsyncAfterTransmissionInterceptorCallingResponseHandler

public AsyncAfterTransmissionInterceptorCallingResponseHandler(TransformingAsyncResponseHandler<T> delegate,
                                                               ExecutionContext context)

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

Specified by:

prepare in interface TransformingAsyncResponseHandler<T>

Returns:

The future holding the transformed response.