public class DefaultChannelPromise extends DefaultPromise<java.lang.Void> implements ChannelPromise
ChannelPromise
implementation. It is recommended to use ChannelOutboundInvoker.newPromise()
to create
a new ChannelPromise
rather than calling the constructor explicitly.构造器和说明 |
---|
DefaultChannelPromise(Channel channel)
Creates a new instance.
|
DefaultChannelPromise(Channel channel,
EventExecutor executor)
Creates a new instance.
|
限定符和类型 | 方法和说明 |
---|---|
ChannelPromise |
addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
Adds the specified listener to this future.
|
ChannelPromise |
addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
Adds the specified listeners to this future.
|
ChannelPromise |
await()
Waits for this future to be completed.
|
ChannelPromise |
awaitUninterruptibly()
Waits for this future to be completed without
interruption.
|
Channel |
channel()
Returns a channel where the I/O operation associated with this
future takes place.
|
protected void |
checkDeadLock() |
protected EventExecutor |
executor()
Get the executor used to notify listeners when this promise is complete.
|
long |
flushCheckpoint() |
void |
flushCheckpoint(long checkpoint) |
boolean |
isVoid()
Returns
true if this ChannelFuture is a void future and so not allow to call any of the
following methods:
ChannelFuture.addListener(GenericFutureListener)
ChannelFuture.addListeners(GenericFutureListener[])
ChannelFuture.await()
Future.await(long, TimeUnit) ()}
Future.await(long) ()}
ChannelFuture.awaitUninterruptibly()
ChannelFuture.sync()
ChannelFuture.syncUninterruptibly()
|
ChannelPromise |
promise() |
ChannelPromise |
removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
Removes the first occurrence of the specified listener from this future.
|
ChannelPromise |
removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
Removes the first occurrence for each of the listeners from this future.
|
ChannelPromise |
setFailure(java.lang.Throwable cause)
Marks this future as a failure and notifies all
listeners.
|
ChannelPromise |
setSuccess() |
ChannelPromise |
setSuccess(java.lang.Void result)
Marks this future as a success and notifies all
listeners.
|
ChannelPromise |
sync()
Waits for this future until it is done, and rethrows the cause of the failure if this future
failed.
|
ChannelPromise |
syncUninterruptibly()
Waits for this future until it is done, and rethrows the cause of the failure if this future
failed.
|
boolean |
trySuccess() |
ChannelPromise |
unvoid()
|
await, await, awaitUninterruptibly, awaitUninterruptibly, cancel, cause, get, get, getNow, isCancellable, isCancelled, isDone, isSuccess, notifyListener, setUncancellable, toString, toStringBuilder, tryFailure, trySuccess
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setUncancellable, tryFailure, trySuccess
await, await, awaitUninterruptibly, awaitUninterruptibly, cancel, cause, getNow, isCancellable, isSuccess
public DefaultChannelPromise(Channel channel)
channel
- the Channel
associated with this futurepublic DefaultChannelPromise(Channel channel, EventExecutor executor)
channel
- the Channel
associated with this futureprotected EventExecutor executor()
DefaultPromise
It is assumed this executor will protect against StackOverflowError
exceptions.
The executor may be used to avoid StackOverflowError
by executing a Runnable
if the stack
depth exceeds a threshold.
executor
在类中 DefaultPromise<java.lang.Void>
public Channel channel()
ChannelFuture
channel
在接口中 ChannelFuture
channel
在接口中 ChannelPromise
public ChannelPromise setSuccess()
setSuccess
在接口中 ChannelPromise
public ChannelPromise setSuccess(java.lang.Void result)
Promise
IllegalStateException
.setSuccess
在接口中 ChannelPromise
setSuccess
在接口中 Promise<java.lang.Void>
setSuccess
在类中 DefaultPromise<java.lang.Void>
public boolean trySuccess()
trySuccess
在接口中 ChannelPromise
public ChannelPromise setFailure(java.lang.Throwable cause)
Promise
IllegalStateException
.setFailure
在接口中 ChannelPromise
setFailure
在接口中 Promise<java.lang.Void>
setFailure
在类中 DefaultPromise<java.lang.Void>
public ChannelPromise addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
Future
addListener
在接口中 ChannelFuture
addListener
在接口中 ChannelPromise
addListener
在接口中 Promise<java.lang.Void>
addListener
在类中 DefaultPromise<java.lang.Void>
public ChannelPromise addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
Future
addListeners
在接口中 ChannelFuture
addListeners
在接口中 ChannelPromise
addListeners
在接口中 Promise<java.lang.Void>
addListeners
在类中 DefaultPromise<java.lang.Void>
public ChannelPromise removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
Future
removeListener
在接口中 ChannelFuture
removeListener
在接口中 ChannelPromise
removeListener
在接口中 Promise<java.lang.Void>
removeListener
在类中 DefaultPromise<java.lang.Void>
public ChannelPromise removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
Future
removeListeners
在接口中 ChannelFuture
removeListeners
在接口中 ChannelPromise
removeListeners
在接口中 Promise<java.lang.Void>
removeListeners
在类中 DefaultPromise<java.lang.Void>
public ChannelPromise sync() throws java.lang.InterruptedException
Future
sync
在接口中 ChannelFuture
sync
在接口中 ChannelPromise
sync
在接口中 Promise<java.lang.Void>
sync
在类中 DefaultPromise<java.lang.Void>
java.lang.InterruptedException
public ChannelPromise syncUninterruptibly()
Future
syncUninterruptibly
在接口中 ChannelFuture
syncUninterruptibly
在接口中 ChannelPromise
syncUninterruptibly
在接口中 Promise<java.lang.Void>
syncUninterruptibly
在类中 DefaultPromise<java.lang.Void>
public ChannelPromise await() throws java.lang.InterruptedException
Future
await
在接口中 ChannelFuture
await
在接口中 ChannelPromise
await
在接口中 Promise<java.lang.Void>
await
在类中 DefaultPromise<java.lang.Void>
java.lang.InterruptedException
- if the current thread was interruptedpublic ChannelPromise awaitUninterruptibly()
Future
InterruptedException
and
discards it silently.awaitUninterruptibly
在接口中 ChannelFuture
awaitUninterruptibly
在接口中 ChannelPromise
awaitUninterruptibly
在接口中 Promise<java.lang.Void>
awaitUninterruptibly
在类中 DefaultPromise<java.lang.Void>
public long flushCheckpoint()
public void flushCheckpoint(long checkpoint)
public ChannelPromise promise()
protected void checkDeadLock()
checkDeadLock
在类中 DefaultPromise<java.lang.Void>
public ChannelPromise unvoid()
ChannelPromise
unvoid
在接口中 ChannelPromise
public boolean isVoid()
ChannelFuture
true
if this ChannelFuture
is a void future and so not allow to call any of the
following methods:
isVoid
在接口中 ChannelFuture