Class ResumableUploadCallableImpl<RequestT,ResponseT> (2.87.0)

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.

Inheritance

java.lang.Object > ResumableUploadCallable > ResumableUploadCallableImpl<RequestT,ResponseT>

Type Parameters

Name Description
RequestT
ResponseT

Constructors

ResumableUploadCallableImpl(ResumableUploadClient<RequestT,ResponseT> client, ResumableUploadOptions defaultOptions, ClientContext clientContext)

public ResumableUploadCallableImpl(ResumableUploadClient<RequestT,ResponseT> client, ResumableUploadOptions defaultOptions, ClientContext clientContext)
Parameters
Name Description
client ResumableUploadClient<RequestT,ResponseT>
defaultOptions ResumableUploadOptions
clientContext ClientContext

Methods

futureCall(RequestT request, InputStreamSupplier payload, @Nullable ApiCallContext context, @Nullable ResumableUploadOptions options)

public ResumableUploadFuture<ResponseT> futureCall(RequestT request, InputStreamSupplier payload, @Nullable ApiCallContext context, @Nullable ResumableUploadOptions options)

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

Streams from the provided payload are consumed asynchronously by the returned ResumableUploadFuture and will be closed automatically upon completion, failure, or cancellation.

Parameters
Name Description
request RequestT
payload InputStreamSupplier
context @org.jspecify.annotations.Nullable com.google.api.gax.rpc.ApiCallContext
options @org.jspecify.annotations.Nullable com.google.api.gax.rpc.ResumableUploadOptions
Returns
Type Description
ResumableUploadFuture<ResponseT>
Overrides

resumeCall(String sessionUrl, InputStreamSupplier payload, @Nullable ResumableUploadOptions options)

public ResumableUploadFuture<ResponseT> resumeCall(String sessionUrl, InputStreamSupplier payload, @Nullable ResumableUploadOptions options)

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

Streams from the provided payload are consumed asynchronously by the returned ResumableUploadFuture and will be closed automatically upon completion, failure, or cancellation.

Parameters
Name Description
sessionUrl String
payload InputStreamSupplier
options @org.jspecify.annotations.Nullable com.google.api.gax.rpc.ResumableUploadOptions
Returns
Type Description
ResumableUploadFuture<ResponseT>
Overrides