com.basho.riak.client.api.commands

Class CoreFutureAdapter<T2,S2,T,S>

java.lang.Object

com.basho.riak.client.api.commands.ListenableFuture<T2,S2>

com.basho.riak.client.api.commands.CoreFutureAdapter<T2,S2,T,S>

Type Parameters:

T - The core response type.

S - The core query info type.

T2 - The converted response type.

S2 - The converted query info type.

All Implemented Interfaces:

RiakFuture<T2,S2>, RiakFutureListener<T,S>, Future<T2>

Direct Known Subclasses:

BigIntIndexQuery.BigIntQueryFuture, BinIndexQuery.BinQueryFuture, IntIndexQuery.IntQueryFuture, RawIndexQuery.RawQueryFuture

public abstract class CoreFutureAdapter<T2,S2,T,S>
extends ListenableFuture<T2,S2>
implements RiakFutureListener<T,S>

Since:

2.0

Author:

Brian Roach

Constructor Summary

Constructors

Constructor and Description
CoreFutureAdapter(RiakFuture<T,S> coreFuture)

Method Summary

Methods

Modifier and Type	Method and Description
void	await() Waits for this RiakFuture to be completed.
void	await(long timeout, TimeUnit unit) Waits for this RiakFuture to be completed, or times out.
boolean	cancel(boolean mayInterruptIfRunning)
Throwable	cause() Return information about the operation and why it failed.
protected abstract S2	convertQueryInfo(S coreQueryInfo)
protected abstract T2	convertResponse(T coreResponse)
T2	get()
T2	get(long timeout, TimeUnit unit)
S2	getQueryInfo() Returns information related to the operation performed.
void	handle(RiakFuture<T,S> f)
boolean	isCancelled()
boolean	isDone()
boolean	isSuccess() Determine if the operation was successful.

Methods inherited from class com.basho.riak.client.api.commands.ListenableFuture

addListener, notifyListeners, removeListener

Methods inherited from class java.lang.Object

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

Constructor Detail

CoreFutureAdapter

public CoreFutureAdapter(RiakFuture<T,S> coreFuture)

Method Detail

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface RiakFuture<T2,S2>

Specified by:

cancel in interface Future<T2>

get

public T2 get()
       throws InterruptedException

Specified by:

get in interface RiakFuture<T2,S2>

Specified by:

get in interface Future<T2>

Throws:

InterruptedException

get

public T2 get(long timeout,
     TimeUnit unit)
       throws InterruptedException

Specified by:

get in interface RiakFuture<T2,S2>

Specified by:

get in interface Future<T2>

Throws:

InterruptedException

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface RiakFuture<T2,S2>

Specified by:

isCancelled in interface Future<T2>

isDone

public boolean isDone()

Specified by:

isDone in interface RiakFuture<T2,S2>

Specified by:

isDone in interface Future<T2>

await

public void await()
           throws InterruptedException

Description copied from interface: RiakFuture

Waits for this RiakFuture to be completed.

Specified by:

await in interface RiakFuture<T2,S2>

Throws:

InterruptedException

await

public void await(long timeout,
         TimeUnit unit)
           throws InterruptedException

Description copied from interface: RiakFuture

Waits for this RiakFuture to be completed, or times out.

Specified by:

await in interface RiakFuture<T2,S2>

Parameters:

timeout - the amount of time to wait before returning.

unit - the unit of time.

Throws:

InterruptedException

isSuccess

public boolean isSuccess()

Description copied from interface: RiakFuture

Determine if the operation was successful.

Specified by:

isSuccess in interface RiakFuture<T2,S2>

Returns:

true if completed and successful, false otherwise.

cause

public Throwable cause()

Description copied from interface: RiakFuture

Return information about the operation and why it failed.

Specified by:

cause in interface RiakFuture<T2,S2>

Returns:

The exception thrown during the operation, or null if not set.

getQueryInfo

public S2 getQueryInfo()

Description copied from interface: RiakFuture

Returns information related to the operation performed.

Useful in async operations when you want to know what operation this future refers to.

Specified by:

getQueryInfo in interface RiakFuture<T2,S2>

Returns:

Information pertaining to the operation attached to this future.

handle

public void handle(RiakFuture<T,S> f)

Specified by:

handle in interface RiakFutureListener<T,S>

convertResponse

protected abstract T2 convertResponse(T coreResponse)

convertQueryInfo

protected abstract S2 convertQueryInfo(S coreQueryInfo)