com.scaleoutsoftware.soss.client.util

Class TransformingFuture<T,V>

java.lang.Object

com.scaleoutsoftware.soss.client.util.TransformingFuture<T,V>

All Implemented Interfaces:

ListenableFuture<T>, java.util.concurrent.Future<T>

public abstract class TransformingFuture<T,V>
extends java.lang.Object
implements ListenableFuture<T>

An adapter class that delegates implementation of Future methods to an existing Future instance while providing a callback (transform(V)) to complete processing when the operation completes. The callback typically transforms the type of the delegate future into a future of a new type.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TransformingFuture(ListenableFuture<V> delegateFuture)

Method Summary

Modifier and Type	Method and Description
void	addListener(FutureListener<T> callback) Add a listener to this Future which will be called when the async operation completes.
boolean	cancel(boolean mayInterruptIfRunning)
T	get()
T	get(long timeout, java.util.concurrent.TimeUnit unit)
boolean	isCancelled()
boolean	isDone()
void	removeListener(FutureListener<T> callback) Remove a previously-registered listener from collection of listeners for this Future.
protected abstract T	transform(V value)

Methods inherited from class java.lang.Object

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

Constructor Detail

TransformingFuture

protected TransformingFuture(ListenableFuture<V> delegateFuture)

Method Detail

transform

protected abstract T transform(V value)

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface java.util.concurrent.Future<T>

get

public T get()
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException

Specified by:

get in interface java.util.concurrent.Future<T>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

get

public T get(long timeout,
             java.util.concurrent.TimeUnit unit)
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException,
             java.util.concurrent.TimeoutException

Specified by:

get in interface java.util.concurrent.Future<T>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface java.util.concurrent.Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface java.util.concurrent.Future<T>

addListener

public void addListener(FutureListener<T> callback)

Description copied from interface: ListenableFuture

Add a listener to this Future which will be called when the async operation completes. If the async operation has already completed, the listener will be called immediately.

Specified by:

addListener in interface ListenableFuture<T>

Parameters:

callback - a FutureListener implementation to call when the operation completes

removeListener

public void removeListener(FutureListener<T> callback)

Description copied from interface: ListenableFuture

Remove a previously-registered listener from collection of listeners for this Future. The listener will not be called which will be called when the async operation completes. If listener is not currently registered, this method is a nop.

Specified by:

removeListener in interface ListenableFuture<T>

Parameters:

callback - a previously-registered FutureListener implementation to remove from the list of callback to call when the operation completes