Package com.google.api.gax.rpc

Class ResumableUploadCallableImpl<RequestT,ResponseT>

java.lang.Object

com.google.api.gax.rpc.ResumableUploadCallable<RequestT,ResponseT>

com.google.api.gax.rpc.ResumableUploadCallableImpl<RequestT,ResponseT>

Type Parameters:

RequestT - the type of the initial request message that initiates the upload session

ResponseT - the type of the final response message returned once the upload completes

@BetaApi
@InternalApi
@NullMarked
public class ResumableUploadCallableImpl<RequestT,ResponseT>
extends ResumableUploadCallable<RequestT,ResponseT>

Concrete implementation of ResumableUploadCallable that delegates the end-to-end management of a resumable upload session to ResumableUploadFutureImpl.

Constructor Summary

Constructors

Constructor	Description
ResumableUploadCallableImpl(ResumableUploadClient<RequestT,ResponseT> client, ResumableUploadCallSettings defaultCallSettings, ClientContext clientContext)

Method Summary

Modifier and Type	Method	Description
ResumableUploadFuture<ResponseT>	futureCall(RequestT request, InputStream payload, @Nullable ApiCallContext context, @Nullable ResumableUploadCallSettings settings)	Performs a new resumable upload asynchronously with call context and settings overrides.
ResumableUploadFuture<ResponseT>	resumeCall(String sessionUrl, InputStream payload, @Nullable ResumableUploadCallSettings settings)	Resumes an existing resumable upload session asynchronously using a saved session URL.

Methods inherited from class com.google.api.gax.rpc.ResumableUploadCallable

futureCall

Methods inherited from class java.lang.Object

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

Constructor Details

ResumableUploadCallableImpl

public ResumableUploadCallableImpl(ResumableUploadClient<RequestT,ResponseT> client,
 ResumableUploadCallSettings defaultCallSettings,
 ClientContext clientContext)

Method Details

futureCall

public ResumableUploadFuture<ResponseT> futureCall(RequestT request,
 InputStream payload,
 @Nullable ApiCallContext context,
 @Nullable ResumableUploadCallSettings settings)

Description copied from class: ResumableUploadCallable

Performs a new resumable upload asynchronously with call context and settings overrides.

The provided payload stream is consumed asynchronously by the returned ResumableUploadFuture and will be closed automatically upon completion, failure, or cancellation.

Specified by:

futureCall in class ResumableUploadCallable<RequestT,ResponseT>

Parameters:

request - the request message

payload - the data payload input stream to upload and close

context - call context overrides; may be null

settings - request-level call settings overrides; may be null

Returns:

future for tracking and controlling the upload

resumeCall

public ResumableUploadFuture<ResponseT> resumeCall(String sessionUrl,
 InputStream payload,
 @Nullable ResumableUploadCallSettings settings)

Description copied from class: ResumableUploadCallable

Resumes an existing resumable upload session asynchronously using a saved session URL.

The provided payload stream is consumed asynchronously by the returned ResumableUploadFuture and will be closed automatically upon completion, failure, or cancellation.

Specified by:

resumeCall in class ResumableUploadCallable<RequestT,ResponseT>

Parameters:

sessionUrl - the upload session URL

payload - the data payload input stream to upload and close

settings - call settings overrides; may be null

Returns:

future for tracking and controlling the upload