Package septogeddon.pluginquery

Class QueryChannelFuture<T>

java.lang.Object

septogeddon.pluginquery.QueryFutureAdapter<T>

septogeddon.pluginquery.QueryChannelFuture<T>

All Implemented Interfaces:

io.netty.channel.ChannelFutureListener, io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture>, EventListener, QueryFuture<T>

public class QueryChannelFuture<T>
extends QueryFutureAdapter<T>
implements io.netty.channel.ChannelFutureListener

Field Summary

Fields inherited from class septogeddon.pluginquery.QueryFutureAdapter

cause, done, result

Fields inherited from interface io.netty.channel.ChannelFutureListener

CLOSE, CLOSE_ON_FAILURE, FIRE_EXCEPTION_ON_FAILURE

Constructor Summary

Constructors

Constructor	Description
QueryChannelFuture(io.netty.channel.ChannelFuture future, T defaultResult)

Method Summary

Modifier and Type	Method	Description
void	joinThread()	Force to wait current thread until the task finished
void	joinThread(long timeout)	Force to wait current thread until the task finished, will ignore if its too long specified by timeout
void	operationComplete(io.netty.channel.ChannelFuture arg0)

Methods inherited from class septogeddon.pluginquery.QueryFutureAdapter

addListener, complete, completeExceptionally, fireEvent, getCause, getResult, isDone, isSuccess, removeListener

Methods inherited from class java.lang.Object

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

Methods inherited from interface septogeddon.pluginquery.api.QueryFuture

printStackTrace, thenAccept

Constructor Details

QueryChannelFuture

public QueryChannelFuture(io.netty.channel.ChannelFuture future,
 T defaultResult)

Method Details

joinThread

public void joinThread()

Description copied from interface: QueryFuture

Force to wait current thread until the task finished

Specified by:

joinThread in interface QueryFuture<T>

joinThread

public void joinThread(long timeout)

Description copied from interface: QueryFuture

Force to wait current thread until the task finished, will ignore if its too long specified by timeout

Specified by:

joinThread in interface QueryFuture<T>

Parameters:

timeout -

operationComplete

public void operationComplete(io.netty.channel.ChannelFuture arg0)
                       throws Exception

Specified by:

operationComplete in interface io.netty.util.concurrent.GenericFutureListener<T>

Throws:

Exception