Package septogeddon.pluginquery.library.remote

Class RemoteFuture

java.lang.Object

septogeddon.pluginquery.library.remote.RemoteFuture

All Implemented Interfaces:

Consumer<QueryFuture<QueryConnection>>

Direct Known Subclasses:

RemoteMethodInvocationFuture

public class RemoteFuture
extends Object
implements Consumer<QueryFuture<QueryConnection>>

Wrapped completable future and QueryFutureListener

Author:

Thito Yalasatria Sunarya

Constructor Summary

Constructors

Constructor	Description
RemoteFuture()

Method Summary

Modifier and Type	Method	Description
void	accept(QueryFuture<QueryConnection> t)	Dispatch for QueryFutureListener event
void	complete(Object obj)	Complete the future
void	completeExceptionally(Throwable thrown)	Indicate that the task failed to execute
Object	get()	Wait until the task done
Object	get(long timeout, TimeUnit unit)	Wait until the task done

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Details

RemoteFuture

public RemoteFuture()

Method Details

complete

public void complete(Object obj)

Complete the future

Parameters:

obj -

completeExceptionally

public void completeExceptionally(Throwable thrown)

Indicate that the task failed to execute

Parameters:

thrown -

get

public Object get()
           throws InterruptedException,
ExecutionException

Wait until the task done

Returns:

the expected object

Throws:

InterruptedException - if the thread got interrupted

ExecutionException - if the task failed to execute

get

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

Wait until the task done

Parameters:

timeout - timeout time

unit - the time unit

Returns:

the expected object

Throws:

InterruptedException - if the thread got interrupted

ExecutionException - if the task failed to execute

TimeoutException - if the wait time reaches the timeout time

accept

public void accept(QueryFuture<QueryConnection> t)

Dispatch for QueryFutureListener event

Specified by:

accept in interface Consumer<QueryFuture<QueryConnection>>