com.ibm.cos.v2.transfer.s3.internal.progress

Class TransferProgressUpdater

java.lang.Object

com.ibm.cos.v2.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 and Description
TransferProgressUpdater(TransferObjectRequest request, Long contentLength)

Method Summary

Modifier and Type	Method and Description
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)
<ResultT> AsyncResponseTransformer<GetObjectResponse,ResultT>	wrapResponseTransformerForMultipartDownload(AsyncResponseTransformer<GetObjectResponse,ResultT> responseTransformer, GetObjectRequest request)

Methods inherited from class java.lang.Object

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

Constructor Detail

TransferProgressUpdater

public TransferProgressUpdater(TransferObjectRequest request,
                               Long contentLength)

Method Detail

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.

wrapResponseTransformerForMultipartDownload

public <ResultT> AsyncResponseTransformer<GetObjectResponse,ResultT> wrapResponseTransformerForMultipartDownload(AsyncResponseTransformer<GetObjectResponse,ResultT> responseTransformer,
                                                                                                                 GetObjectRequest request)

wrapResponseTransformer

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

registerCompletion

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