Class OperationFutureImpl<ResponseT,MetadataT> (2.33.0)

public final class OperationFutureImpl<ResponseT,MetadataT> implements OperationFuture<ResponseT,MetadataT>

An ApiFuture which tracks polling of a service. The polling is done periodically, based on the com.google.api.gax.retrying.TimedRetryAlgorithm.

This class is thread-safe.

This is public only for technical reasons, for advanced usage.

Inheritance

java.lang.Object > OperationFutureImpl<ResponseT,MetadataT>

Implements

com.google.api.gax.longrunning.OperationFuture<ResponseT,MetadataT>

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Type Parameters
Name	Description
`ResponseT`
`MetadataT`

Constructors

OperationFutureImpl(RetryingFuture<OperationSnapshot> pollingFuture, ApiFuture<OperationSnapshot> initialFuture, ApiFunction<OperationSnapshot,ResponseT> responseTransformer, ApiFunction<OperationSnapshot,MetadataT> metadataTransformer)

public OperationFutureImpl(RetryingFuture<OperationSnapshot> pollingFuture, ApiFuture<OperationSnapshot> initialFuture, ApiFunction<OperationSnapshot,ResponseT> responseTransformer, ApiFunction<OperationSnapshot,MetadataT> metadataTransformer)

Creates a new operation future instance.

Parameters
Name	Description
`pollingFuture`	`RetryingFuture<OperationSnapshot>` retrying future which tracks polling of the server operation (in most cases with exponential upper bounded intervals)
`initialFuture`	`ApiFuture<OperationSnapshot>` the initial future which started the operation on the server side
`responseTransformer`	`ApiFunction<OperationSnapshot,ResponseT>`
`metadataTransformer`	`ApiFunction<OperationSnapshot,MetadataT>`

OperationFutureImpl(RetryingFuture<OperationSnapshot> pollingFuture, ApiFuture<OperationSnapshot> initialFuture, ApiFunction<OperationSnapshot,ResponseT> responseTransformer, ApiFunction<OperationSnapshot,MetadataT> metadataTransformer, ApiFunction<Exception,ResponseT> exceptionTransformer)

public OperationFutureImpl(RetryingFuture<OperationSnapshot> pollingFuture, ApiFuture<OperationSnapshot> initialFuture, ApiFunction<OperationSnapshot,ResponseT> responseTransformer, ApiFunction<OperationSnapshot,MetadataT> metadataTransformer, ApiFunction<Exception,ResponseT> exceptionTransformer)

Parameters
Name	Description
`pollingFuture`	`RetryingFuture<OperationSnapshot>`
`initialFuture`	`ApiFuture<OperationSnapshot>`
`responseTransformer`	`ApiFunction<OperationSnapshot,ResponseT>`
`metadataTransformer`	`ApiFunction<OperationSnapshot,MetadataT>`
`exceptionTransformer`	`ApiFunction<Exception,ResponseT>`

Methods

addListener(Runnable listener, Executor executor)

public void addListener(Runnable listener, Executor executor)

Parameters
Name	Description
`listener`	`Runnable`
`executor`	`Executor`

cancel(boolean mayInterruptIfRunning)

public boolean cancel(boolean mayInterruptIfRunning)

Parameter
Name	Description
`mayInterruptIfRunning`	`boolean`

Returns
Type	Description
`boolean`

get()

public ResponseT get()

Returns
Type	Description
`ResponseT`

Exceptions
Type	Description
`InterruptedException`
`ExecutionException`

get(long timeout, TimeUnit unit)

public ResponseT get(long timeout, TimeUnit unit)

Parameters
Name	Description
`timeout`	`long`
`unit`	`TimeUnit`

Returns
Type	Description
`ResponseT`

Exceptions
Type	Description
`InterruptedException`
`ExecutionException`
`TimeoutException`

getInitialFuture()

public ApiFuture<OperationSnapshot> getInitialFuture()

Returns the OperationSnapshot future of the initial request which started this OperationFuture.

Returns
Type	Description
`ApiFuture<OperationSnapshot>`

getMetadata()

public ApiFuture<MetadataT> getMetadata()

Gets the metadata of the operation tracked by this OperationFuture. This method returns the current poll metadata result (or the initial call metadata if it hasn't completed yet). The returned future completes once the current scheduled poll request (or the initial request if it hasn't completed yet) is executed and response is received from the server. The time when the polling request is executed is determined by the underlying polling algorithm.

Adding direct executor (same thread) callbacks to the future returned by this method is strongly not recommended, since the future is resolved under retrying future's internal lock and may affect the operation polling process. Adding separate thread callbacks is ok.

Note, some APIs may return null in metadata response message. In such cases this method may return a non-null future whose get() method will return null. This behavior is API specific an should be considered a valid case, which indicates that the recent poll request has completed, but no specific metadata was provided by the server. (i.e. most probably providing metadata for an intermediate result is not supported by the server).

In most cases this method returns a future which is not completed yet, so calling ApiFuture#get() is a potentially blocking operation. To get metadata without blocking the current thread use the #peekMetadata() method instead.

If this operation future is completed, this method always returns the metadata from the last poll request (which completed the operation future).

If this operation future failed, this method may (depending on the failure type) return a non-failing future, representing the metadata from the last poll request (which failed the operation future).

If this operation future was cancelled, this method returns a canceled metatata future as well.

In general this method behaves similarly to RetryingFuture#getAttemptResult().

Returns
Type	Description
`ApiFuture<MetadataT>`

getName()

public String getName()

Returns the value of the name of the operation from the initial operation object returned from the initial call to start the operation. Blocks if the initial call to start the operation hasn't returned yet.

Returns
Type	Description
`String`

Exceptions
Type	Description
`ExecutionException`
`InterruptedException`

getPollingFuture()

public RetryingFuture<OperationSnapshot> getPollingFuture()

Returns the RetryingFuture which continues to poll OperationSnapshot.

Returns
Type	Description
`RetryingFuture<OperationSnapshot>`

isCancelled()

public boolean isCancelled()

Returns
Type	Description
`boolean`

isDone()

public boolean isDone()

Returns
Type	Description
`boolean`

peekMetadata()

public ApiFuture<MetadataT> peekMetadata()

Peeks at the metadata of the operation tracked by this OperationFuture. If the initial future hasn't completed yet this method returns null, otherwise it returns the latest metadata returned from the server (i.e. either initial call metadata or the metadata received from the latest completed poll iteration).

If not null, the returned result is guaranteed to be an already completed future, so ApiFuture#isDone() will always be true and ApiFuture#get() will always be non-blocking.

Note, some APIs may return null in metadata response message. In such cases this method may return a non-null future whose get() method will return null. This behavior is API specific an should be considered a valid case, which indicates that the recent poll request has completed, but no specific metadata was provided by the server (i.e. most probably providing metadata for an intermediate result is not supported by the server).

This method should be used to check operation progress without blocking current thread. Since this method returns metadata from the latest completed poll, it is potentially slightly stale compared to the most recent data. To get the most recent data and/or get notified when the current scheduled poll request completes use the #getMetadata() method instead.