com.ibm.cos.v2.services.s3.internal.multipart

Class GenericMultipartHelper<RequestT extends S3Request,ResponseT extends S3Response>

java.lang.Object

com.ibm.cos.v2.services.s3.internal.multipart.GenericMultipartHelper<RequestT,ResponseT>

public final class GenericMultipartHelper<RequestT extends S3Request,ResponseT extends S3Response>
extends Object

Constructor Summary

Constructors

Constructor and Description
GenericMultipartHelper(S3AsyncClient s3AsyncClient, Function<RequestT,AbortMultipartUploadRequest.Builder> abortMultipartUploadRequestConverter, Function<CompleteMultipartUploadResponse,ResponseT> responseConverter)

Method Summary

Modifier and Type	Method and Description
long	calculateOptimalPartSizeFor(long contentLengthOfSource, long partSizeInBytes)
void	cleanUpParts(String uploadId, AbortMultipartUploadRequest.Builder abortMultipartUploadRequest)
CompletableFuture<CompleteMultipartUploadResponse>	completeMultipartUpload(PutObjectRequest request, String uploadId, CompletedPart[] parts, long contentLength)
int	determinePartCount(long contentLength, long partSize)
void	handleException(CompletableFuture<ResponseT> returnFuture, Supplier<String> message, Throwable throwable)
BiFunction<CompleteMultipartUploadResponse,Throwable,Void>	handleExceptionOrResponse(RequestT request, CompletableFuture<ResponseT> returnFuture, String uploadId)

Methods inherited from class java.lang.Object

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

Constructor Detail

GenericMultipartHelper

public GenericMultipartHelper(S3AsyncClient s3AsyncClient,
                              Function<RequestT,AbortMultipartUploadRequest.Builder> abortMultipartUploadRequestConverter,
                              Function<CompleteMultipartUploadResponse,ResponseT> responseConverter)

Method Detail

handleException

public void handleException(CompletableFuture<ResponseT> returnFuture,
                            Supplier<String> message,
                            Throwable throwable)

calculateOptimalPartSizeFor

public long calculateOptimalPartSizeFor(long contentLengthOfSource,
                                        long partSizeInBytes)

determinePartCount

public int determinePartCount(long contentLength,
                              long partSize)

completeMultipartUpload

public CompletableFuture<CompleteMultipartUploadResponse> completeMultipartUpload(PutObjectRequest request,
                                                                                  String uploadId,
                                                                                  CompletedPart[] parts,
                                                                                  long contentLength)

handleExceptionOrResponse

public BiFunction<CompleteMultipartUploadResponse,Throwable,Void> handleExceptionOrResponse(RequestT request,
                                                                                            CompletableFuture<ResponseT> returnFuture,
                                                                                            String uploadId)

cleanUpParts

public void cleanUpParts(String uploadId,
                         AbortMultipartUploadRequest.Builder abortMultipartUploadRequest)