io.confluent.license.util

Class ConvertingFutureCallback<U,T>

java.lang.Object

io.confluent.license.util.ConvertingFutureCallback<U,T>

Type Parameters:

U - the callback result type

T - the future result type obtained after converting the callback result

All Implemented Interfaces:

Callback<U>, Future<T>

Direct Known Subclasses:

FutureCallback

public abstract class ConvertingFutureCallback<U,T>
extends Object
implements Callback<U>, Future<T>

An abstract implementation of Callback that also implements the Future interface. This allows for operations like waiting until the callback is completed via onCompletion(Throwable, Object). The result from the callback can be converted by concrete implementations of this class before being retrieved via Future.get().

Constructor Summary

Constructors

Constructor and Description
ConvertingFutureCallback()
ConvertingFutureCallback(Callback<T> underlying)

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
abstract T	convert(U result)
T	get()
T	get(long l, TimeUnit timeUnit)
boolean	isCancelled()
boolean	isDone()
void	onCompletion(Throwable error, U result) Invoked upon completion of the operation.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConvertingFutureCallback

public ConvertingFutureCallback()

ConvertingFutureCallback

public ConvertingFutureCallback(Callback<T> underlying)

Method Detail

convert

public abstract T convert(U result)

onCompletion

public void onCompletion(Throwable error,
                         U result)

Description copied from interface: Callback

Invoked upon completion of the operation.

Specified by:

onCompletion in interface Callback<U>

Parameters:

error - the error that caused the operation to fail, or null if no error occurred

result - the return value, or null if the operation failed

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>

get

public T get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

get

public T get(long l,
             TimeUnit timeUnit)
      throws InterruptedException,
             ExecutionException,
             TimeoutException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

TimeoutException