Package software.amazon.awssdk.transfer.s3.internal.progress

Class TransferProgressUpdater

java.lang.Object

software.amazon.awssdk.transfer.s3.internal.progress.TransferProgressUpdater

public class TransferProgressUpdater
extends Object

An SDK-internal helper class that facilitates updating a TransferProgress and invoking TransferListeners.

Constructor Summary

Constructors

Constructor	Description
TransferProgressUpdater(TransferObjectRequest request, Long contentLength)

Method Summary

Modifier and Type	Method	Description
PublisherListener<software.amazon.awssdk.crt.s3.S3MetaRequestProgress>	crtProgressListener()
PublisherListener<Long>	multipartClientProgressListener()	Progress listener for Java-based S3Client with multipart enabled.
TransferProgress	progress()
void	registerCompletion(CompletableFuture<? extends CompletedObjectTransfer> future)
void	transferInitiated()
AsyncRequestBody	wrapRequestBody(AsyncRequestBody requestBody)
<ResultT> AsyncResponseTransformer<GetObjectResponse,ResultT>	wrapResponseTransformer(AsyncResponseTransformer<GetObjectResponse,ResultT> responseTransformer)

Methods inherited from class java.lang.Object

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

Constructor Details

TransferProgressUpdater

public TransferProgressUpdater(TransferObjectRequest request,
 Long contentLength)

Method Details

progress

public TransferProgress progress()

transferInitiated

public void transferInitiated()

wrapRequestBody

public AsyncRequestBody wrapRequestBody(AsyncRequestBody requestBody)

multipartClientProgressListener

public PublisherListener<Long> multipartClientProgressListener()

Progress listener for Java-based S3Client with multipart enabled.

crtProgressListener

public PublisherListener<software.amazon.awssdk.crt.s3.S3MetaRequestProgress> crtProgressListener()

wrapResponseTransformer

public <ResultT>
AsyncResponseTransformer<GetObjectResponse,ResultT> wrapResponseTransformer(AsyncResponseTransformer<GetObjectResponse,ResultT> responseTransformer)

registerCompletion

public void registerCompletion(CompletableFuture<? extends CompletedObjectTransfer> future)