@UnstableApi public final class DelegatingChannelPromiseNotifier extends java.lang.Object implements ChannelPromise, ChannelFutureListener
CLOSE, CLOSE_ON_FAILURE, FIRE_EXCEPTION_ON_FAILURE| Constructor and Description |
|---|
DelegatingChannelPromiseNotifier(ChannelPromise delegate) |
DelegatingChannelPromiseNotifier(ChannelPromise delegate, boolean logNotifyFailure) |
| Modifier and Type | Method and Description |
|---|---|
ChannelPromise |
addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
将指定的侦听器添加到此将来。
|
ChannelPromise |
addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
将指定的侦听器添加到此将来。
|
ChannelPromise |
await()
等待这个未来的完成。
|
boolean |
await(long timeoutMillis)
等待这个未来在规定的时限内完成。
|
boolean |
await(long timeout, java.util.concurrent.TimeUnit unit)
等待这个未来在规定的时限内完成。
|
ChannelPromise |
awaitUninterruptibly()
等待这个未来不中断地完成。
|
boolean |
awaitUninterruptibly(long timeoutMillis)
等待这个未来在规定的时间内完成而不会中断。
|
boolean |
awaitUninterruptibly(long timeout, java.util.concurrent.TimeUnit unit)
等待这个未来在规定的时间内完成而不会中断。
|
boolean |
cancel(boolean mayInterruptIfRunning)
如果取消成功,将会以
CancellationException失败。
|
java.lang.Throwable |
cause()
如果I / O操作失败,则返回失败的I / O操作的原因。
|
Channel |
channel()
返回与此未来相关的I / O操作发生的通道。
|
java.lang.Void |
get() |
java.lang.Void |
get(long timeout, java.util.concurrent.TimeUnit unit) |
java.lang.Void |
getNow()
无阻塞地返回结果。
|
boolean |
isCancellable()
返回
true当且仅当该操作可通过取消
Future.cancel(boolean) 。
|
boolean |
isCancelled() |
boolean |
isDone() |
boolean |
isSuccess()
当且仅当I / O操作成功完成时返回
true 。
|
boolean |
isVoid()
返回 true如果这ChannelFuture是一个无效的未来,所以不允许调用任何下列方法: ChannelFuture.addListener(GenericFutureListener) ChannelFuture.addListeners(GenericFutureListener[]) ChannelFuture.await() Future.await(long, TimeUnit) ()} Future.await(long) ()} ChannelFuture.awaitUninterruptibly() ChannelFuture.sync() ChannelFuture.syncUninterruptibly()
|
void |
operationComplete(ChannelFuture future)
当与 Future相关的操作完成时调用。
|
ChannelPromise |
removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
从此将来删除指定侦听器的第一个匹配项。
|
ChannelPromise |
removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
为将来的每个听众删除第一个匹配项。
|
ChannelPromise |
setFailure(java.lang.Throwable cause)
将这个未来标志为失败并通知所有听众。
|
ChannelPromise |
setSuccess() |
ChannelPromise |
setSuccess(java.lang.Void result)
将这个未来标志为成功并通知所有听众。
|
boolean |
setUncancellable()
使这个未来无法取消。
|
ChannelPromise |
sync()
等待这个未来,直到完成,并且在这个未来失败的时候重新引发失败的原因。
|
ChannelPromise |
syncUninterruptibly()
等待这个未来,直到完成,并且在这个未来失败的时候重新引发失败的原因。
|
boolean |
tryFailure(java.lang.Throwable cause)
将这个未来标志为失败并通知所有听众。
|
boolean |
trySuccess() |
boolean |
trySuccess(java.lang.Void result)
将这个未来标志为成功并通知所有听众。
|
ChannelPromise |
unvoid()
如果 ChannelFuture.isVoid()返回true则返回新的ChannelPromise 。
|
public DelegatingChannelPromiseNotifier(ChannelPromise delegate)
public DelegatingChannelPromiseNotifier(ChannelPromise delegate, boolean logNotifyFailure)
public void operationComplete(ChannelFuture future) throws java.lang.Exception
GenericFutureListener
Future相关的操作已完成时调用。
operationComplete接口
GenericFutureListener<ChannelFuture>
future - 调用此回调的源Future
java.lang.Exception
public Channel channel()
ChannelFuture
channel在界面
ChannelFuture
channel ,界面
ChannelPromise
public ChannelPromise setSuccess(java.lang.Void result)
Promise复制的描述
IllegalStateException 。
setSuccess在界面
ChannelPromise
setSuccess接口
Promise<java.lang.Void>
public ChannelPromise setSuccess()
setSuccess接口
ChannelPromise
public boolean trySuccess()
trySuccess在界面
ChannelPromise
public boolean trySuccess(java.lang.Void result)
Promise
trySuccess接口
Promise<java.lang.Void>
true当且仅当成功标记这个未来是成功的。
否则false因为这个未来已被标记为成功或失败。
public ChannelPromise setFailure(java.lang.Throwable cause)
Promise
IllegalStateException 。
setFailure ,界面
ChannelPromise
setFailure接口
Promise<java.lang.Void>
public ChannelPromise addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
Future
addListener ,界面
ChannelFuture
addListener接口
ChannelPromise
addListener接口
Promise<java.lang.Void>
public ChannelPromise addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
Future复制的描述
addListeners接口
ChannelFuture
addListeners接口
ChannelPromise
addListeners在界面
Promise<java.lang.Void>
public ChannelPromise removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
Future
removeListener在界面
ChannelFuture
removeListener在界面
ChannelPromise
removeListener ,界面
Promise<java.lang.Void>
public ChannelPromise removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
Future
removeListeners在界面
ChannelFuture
removeListeners接口
ChannelPromise
removeListeners接口
Promise<java.lang.Void>
public boolean tryFailure(java.lang.Throwable cause)
Promise复制的描述
tryFailure在界面
Promise<java.lang.Void>
true当且仅当成功将这个未来标记为失败。
否则false因为这个未来已经被标记为成功或失败。
public boolean setUncancellable()
Promise
setUncancellable接口
Promise<java.lang.Void>
true当且仅当成功地将这个未来标记为不可取消或已经完成而未被取消。
false如果这个未来已经被取消了。
public ChannelPromise await() throws java.lang.InterruptedException
Future
await接口
ChannelFuture
await接口
ChannelPromise
await在界面
Promise<java.lang.Void>
java.lang.InterruptedException - 如果当前线程中断
public ChannelPromise awaitUninterruptibly()
Future
InterruptedException并以静默方式丢弃它。
awaitUninterruptibly在界面
ChannelFuture
awaitUninterruptibly接口
ChannelPromise
awaitUninterruptibly ,界面
Promise<java.lang.Void>
public boolean isVoid()
ChannelFuture
ChannelFuture是一个无效的未来,并且不允许调用以下任何方法,则返回true :
isVoid接口
ChannelFuture
public ChannelPromise unvoid()
ChannelPromise
ChannelFuture.isVoid()返回true则返回新的ChannelPromise 。
unvoid接口
ChannelPromise
public boolean await(long timeout,
java.util.concurrent.TimeUnit unit)
throws java.lang.InterruptedException
Future复制的描述
true当且仅当未来在规定的时限内完成
java.lang.InterruptedException - 如果当前线程中断
public boolean await(long timeoutMillis)
throws java.lang.InterruptedException
Future
true当且仅当未来在规定的时限内完成
java.lang.InterruptedException - 如果当前线程中断
public boolean awaitUninterruptibly(long timeout,
java.util.concurrent.TimeUnit unit)
Future
InterruptedException并以静默方式丢弃它。
true当且仅当未来在规定的时限内完成
public boolean awaitUninterruptibly(long timeoutMillis)
Future
InterruptedException并以静默方式丢弃它。
true当且仅当未来在规定的时限内完成
public java.lang.Void getNow()
Future
null 。
由于可能使用null值标记未来成功,因此您还需要检查未来是否真的用Future.isDone()完成,而不是在返回的null值上进行中继。
public boolean cancel(boolean mayInterruptIfRunning)
Future
CancellationException未来失败。
cancel在界面
java.util.concurrent.Future<java.lang.Void>
public boolean isCancelled()
isCancelled接口
java.util.concurrent.Future<java.lang.Void>
public boolean isDone()
isDone接口
java.util.concurrent.Future<java.lang.Void>
public java.lang.Void get()
throws java.lang.InterruptedException,
java.util.concurrent.ExecutionException
get接口
java.util.concurrent.Future<java.lang.Void>
java.lang.InterruptedException
java.util.concurrent.ExecutionException
public java.lang.Void get(long timeout,
java.util.concurrent.TimeUnit unit)
throws java.lang.InterruptedException,
java.util.concurrent.ExecutionException,
java.util.concurrent.TimeoutException
get接口
java.util.concurrent.Future<java.lang.Void>
java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.util.concurrent.TimeoutException
public ChannelPromise sync() throws java.lang.InterruptedException
Future
sync在界面
ChannelFuture
sync在界面
ChannelPromise
sync接口
Promise<java.lang.Void>
java.lang.InterruptedException
public ChannelPromise syncUninterruptibly()
Future
syncUninterruptibly接口
ChannelFuture
syncUninterruptibly接口
ChannelPromise
syncUninterruptibly ,界面
Promise<java.lang.Void>
public boolean isSuccess()
Future
true 。
public boolean isCancellable()
Future
true当且仅当该操作可通过取消
Future.cancel(boolean) 。
public java.lang.Throwable cause()
Future复制的描述
null如果成功或未来尚未完成。
Copyright © 2008–2018 The Netty Project. All rights reserved.