Class ParallelPresignedUrlMultipartDownloaderSubscriber

java.lang.Object

software.amazon.awssdk.services.s3.internal.multipart.ParallelPresignedUrlMultipartDownloaderSubscriber

All Implemented Interfaces:

org.reactivestreams.Subscriber<AsyncResponseTransformer<GetObjectResponse,GetObjectResponse>>

@SdkInternalApi
public class ParallelPresignedUrlMultipartDownloaderSubscriber
extends Object
implements org.reactivestreams.Subscriber<AsyncResponseTransformer<GetObjectResponse,GetObjectResponse>>

A parallel subscriber for multipart presigned URL downloads that writes parts concurrently. Used with FileAsyncResponseTransformerPublisher when parallelSplitSupported() == true (i.e., toFile() downloads).

Unlike PresignedUrlMultipartDownloaderSubscriber which requests one part at a time, this subscriber requests up to maxInFlightParts concurrently, similar to ParallelMultipartDownloaderSubscriber for regular multipart downloads.

Constructor Summary

Constructors

Constructor	Description
ParallelPresignedUrlMultipartDownloaderSubscriber(S3AsyncClient s3AsyncClient, PresignedUrlDownloadRequest presignedUrlDownloadRequest, long configuredPartSizeInBytes, CompletableFuture<GetObjectResponse> resultFuture, int maxInFlightParts)

Method Summary

Modifier and Type	Method	Description
void	onComplete()
void	onError(Throwable t)
void	onNext(AsyncResponseTransformer<GetObjectResponse,GetObjectResponse> asyncResponseTransformer)
void	onSubscribe(org.reactivestreams.Subscription s)

Methods inherited from class java.lang.Object

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

Constructor Details

ParallelPresignedUrlMultipartDownloaderSubscriber

public ParallelPresignedUrlMultipartDownloaderSubscriber(S3AsyncClient s3AsyncClient,
 PresignedUrlDownloadRequest presignedUrlDownloadRequest,
 long configuredPartSizeInBytes,
 CompletableFuture<GetObjectResponse> resultFuture,
 int maxInFlightParts)

Method Details

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<AsyncResponseTransformer<GetObjectResponse,GetObjectResponse>>

onNext

public void onNext(AsyncResponseTransformer<GetObjectResponse,GetObjectResponse> asyncResponseTransformer)

Specified by:

onNext in interface org.reactivestreams.Subscriber<AsyncResponseTransformer<GetObjectResponse,GetObjectResponse>>

onError

public void onError(Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<AsyncResponseTransformer<GetObjectResponse,GetObjectResponse>>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<AsyncResponseTransformer<GetObjectResponse,GetObjectResponse>>