software.amazon.awssdk.transfer.s3.internal

Class RequestDataSupplierAdapter

java.lang.Object

software.amazon.awssdk.transfer.s3.internal.RequestDataSupplierAdapter

All Implemented Interfaces:

com.amazonaws.s3.OperationHandler, com.amazonaws.s3.RequestDataSupplier

public final class RequestDataSupplierAdapter
extends Object
implements com.amazonaws.s3.RequestDataSupplier

Adapts an SDK AsyncRequestBody to CRT's RequestDataSupplier.

Constructor Summary

Constructors

Constructor and Description
RequestDataSupplierAdapter(org.reactivestreams.Publisher<ByteBuffer> bodyPublisher)

Method Summary

Modifier and Type	Method and Description
software.amazon.awssdk.transfer.s3.internal.RequestDataSupplierAdapter.SubscriberImpl	createSubscriber()
boolean	getRequestBytes(ByteBuffer outBuffer)
void	onException(software.amazon.awssdk.crt.CrtRuntimeException e)
void	onFinished()
void	onResponseHeaders(int statusCode, software.amazon.awssdk.crt.http.HttpHeader[] headers)
boolean	resetPosition()
CompletableFuture<SdkHttpResponse>	sdkHttpResponseFuture()

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestDataSupplierAdapter

public RequestDataSupplierAdapter(org.reactivestreams.Publisher<ByteBuffer> bodyPublisher)

Method Detail

sdkHttpResponseFuture

public CompletableFuture<SdkHttpResponse> sdkHttpResponseFuture()

onResponseHeaders

public void onResponseHeaders(int statusCode,
                              software.amazon.awssdk.crt.http.HttpHeader[] headers)

Specified by:

onResponseHeaders in interface com.amazonaws.s3.OperationHandler

getRequestBytes

public boolean getRequestBytes(ByteBuffer outBuffer)

Specified by:

getRequestBytes in interface com.amazonaws.s3.RequestDataSupplier

resetPosition

public boolean resetPosition()

Specified by:

resetPosition in interface com.amazonaws.s3.RequestDataSupplier

onException

public void onException(software.amazon.awssdk.crt.CrtRuntimeException e)

Specified by:

onException in interface com.amazonaws.s3.OperationHandler

onFinished

public void onFinished()

Specified by:

onFinished in interface com.amazonaws.s3.OperationHandler

createSubscriber

public software.amazon.awssdk.transfer.s3.internal.RequestDataSupplierAdapter.SubscriberImpl createSubscriber()