Package software.amazon.awssdk.http.crt.internal.response

Class InputStreamAdaptingHttpStreamResponseHandler

java.lang.Object

software.amazon.awssdk.http.crt.internal.response.InputStreamAdaptingHttpStreamResponseHandler

All Implemented Interfaces:

software.amazon.awssdk.crt.http.HttpStreamResponseHandler

public final class InputStreamAdaptingHttpStreamResponseHandler
extends Object
implements software.amazon.awssdk.crt.http.HttpStreamResponseHandler

Response handler adaptor for AwsCrtHttpClient.

Constructor Summary

Constructors

Constructor	Description
InputStreamAdaptingHttpStreamResponseHandler(software.amazon.awssdk.crt.http.HttpClientConnection crtConn, CompletableFuture<SdkHttpFullResponse> requestCompletionFuture)
InputStreamAdaptingHttpStreamResponseHandler(software.amazon.awssdk.crt.http.HttpClientConnection crtConn, CompletableFuture<SdkHttpFullResponse> requestCompletionFuture, SimplePublisher<ByteBuffer> simplePublisher)

Method Summary

Modifier and Type	Method	Description
int	onResponseBody(software.amazon.awssdk.crt.http.HttpStream stream, byte[] bodyBytesIn)
void	onResponseComplete(software.amazon.awssdk.crt.http.HttpStream stream, int errorCode)
void	onResponseHeaders(software.amazon.awssdk.crt.http.HttpStream stream, int responseStatusCode, int blockType, software.amazon.awssdk.crt.http.HttpHeader[] nextHeaders)

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.amazon.awssdk.crt.http.HttpStreamResponseHandler

onMetrics, onResponseHeadersDone

Constructor Details

InputStreamAdaptingHttpStreamResponseHandler

public InputStreamAdaptingHttpStreamResponseHandler(software.amazon.awssdk.crt.http.HttpClientConnection crtConn,
 CompletableFuture<SdkHttpFullResponse> requestCompletionFuture)

InputStreamAdaptingHttpStreamResponseHandler

public InputStreamAdaptingHttpStreamResponseHandler(software.amazon.awssdk.crt.http.HttpClientConnection crtConn,
 CompletableFuture<SdkHttpFullResponse> requestCompletionFuture,
 SimplePublisher<ByteBuffer> simplePublisher)

Method Details

onResponseHeaders

public void onResponseHeaders(software.amazon.awssdk.crt.http.HttpStream stream,
 int responseStatusCode,
 int blockType,
 software.amazon.awssdk.crt.http.HttpHeader[] nextHeaders)

Specified by:

onResponseHeaders in interface software.amazon.awssdk.crt.http.HttpStreamResponseHandler

onResponseBody

public int onResponseBody(software.amazon.awssdk.crt.http.HttpStream stream,
 byte[] bodyBytesIn)

Specified by:

onResponseBody in interface software.amazon.awssdk.crt.http.HttpStreamResponseHandler

onResponseComplete

public void onResponseComplete(software.amazon.awssdk.crt.http.HttpStream stream,
 int errorCode)

Specified by:

onResponseComplete in interface software.amazon.awssdk.crt.http.HttpStreamResponseHandler