com.ibm.cloud.objectstorage.services.s3.transfer.internal.future

Class FutureImpl<T>

java.lang.Object

com.ibm.cloud.objectstorage.services.s3.transfer.internal.future.FutureImpl<T>

All Implemented Interfaces:

Future<T>

public class FutureImpl<T>
extends Object
implements Future<T>

An implementation of Future that can be completed successfully or unsuccessfully.

Field Summary

Fields

Modifier and Type	Field and Description
DelegatingFuture<T>	delegatingFuture

Constructor Summary

Constructors

Constructor and Description
FutureImpl()

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
void	complete(T value) Complete this future successfully.
void	fail(Throwable t) Complete this future unsuccessfully.
T	get()
T	get(long timeout, TimeUnit unit)
T	getOrThrowUnchecked(String errorMessage) Call FutureImpl.get(), and re-throw any checked exceptions as an unchecked RuntimeException with the provided message.
boolean	isCancelled()
boolean	isDone()

Methods inherited from class java.lang.Object

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

Field Detail

delegatingFuture

public final DelegatingFuture<T> delegatingFuture

Constructor Detail

FutureImpl

public FutureImpl()

Method Detail

complete

public void complete(T value)

Complete this future successfully.

fail

public void fail(Throwable t)

Complete this future unsuccessfully.

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<T>

getOrThrowUnchecked

public T getOrThrowUnchecked(String errorMessage)

Call FutureImpl.get(), and re-throw any checked exceptions as an unchecked RuntimeException with the provided message.

get

public T get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

get

public T get(long timeout,
             TimeUnit unit)
      throws InterruptedException,
             ExecutionException,
             TimeoutException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

TimeoutException