Class CrtResponseAdapter

java.lang.Object

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

All Implemented Interfaces:

software.amazon.awssdk.crt.http.HttpStreamBaseResponseHandler

@SdkInternalApi
public final class CrtResponseAdapter
extends Object
implements software.amazon.awssdk.crt.http.HttpStreamBaseResponseHandler

Response handler adaptor for AwsCrtAsyncHttpClient.

Implements the CrtHttpStreamHandler API and converts CRT callbacks into calls to SDK AsyncExecuteRequest methods

Constructor Summary

Constructors

Constructor	Description
CrtResponseAdapter(CompletableFuture<Void> completionFuture, SdkAsyncHttpResponseHandler responseHandler, SimplePublisher<ByteBuffer> simplePublisher)

Method Summary

Modifier and Type	Method	Description
int	onResponseBody(software.amazon.awssdk.crt.http.HttpStreamBase stream, byte[] bodyBytesIn)
void	onResponseComplete(software.amazon.awssdk.crt.http.HttpStreamBase stream, int errorCode)
void	onResponseHeaders(software.amazon.awssdk.crt.http.HttpStreamBase stream, int responseStatusCode, int headerType, software.amazon.awssdk.crt.http.HttpHeader[] nextHeaders)
void	onResponseHeadersDone(software.amazon.awssdk.crt.http.HttpStreamBase stream, int headerType)
static software.amazon.awssdk.crt.http.HttpStreamBaseResponseHandler	toCrtResponseHandler(CompletableFuture<Void> requestFuture, SdkAsyncHttpResponseHandler responseHandler)

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.HttpStreamBaseResponseHandler

onMetrics

Constructor Details

CrtResponseAdapter

@SdkTestInternalApi
public CrtResponseAdapter(CompletableFuture<Void> completionFuture,
 SdkAsyncHttpResponseHandler responseHandler,
 SimplePublisher<ByteBuffer> simplePublisher)

Method Details

toCrtResponseHandler

public static software.amazon.awssdk.crt.http.HttpStreamBaseResponseHandler toCrtResponseHandler(CompletableFuture<Void> requestFuture,
 SdkAsyncHttpResponseHandler responseHandler)

onResponseHeaders

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

Specified by:

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

onResponseHeadersDone

public void onResponseHeadersDone(software.amazon.awssdk.crt.http.HttpStreamBase stream,
 int headerType)

Specified by:

onResponseHeadersDone in interface software.amazon.awssdk.crt.http.HttpStreamBaseResponseHandler

onResponseBody

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

Specified by:

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

onResponseComplete

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

Specified by:

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