public interface ProgressivePromise<V> extends Promise<V>, ProgressiveFuture<V>
ProgressiveFuture
这是可写的。
Modifier and Type | Method and Description |
---|---|
ProgressivePromise<V> |
addListener(GenericFutureListener<? extends Future<? super V>> listener)
将指定的侦听器添加到此将来。
|
ProgressivePromise<V> |
addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
将指定的侦听器添加到此将来。
|
ProgressivePromise<V> |
await()
等待这个未来的完成。
|
ProgressivePromise<V> |
awaitUninterruptibly()
等待这个未来不中断地完成。
|
ProgressivePromise<V> |
removeListener(GenericFutureListener<? extends Future<? super V>> listener)
从此将来删除指定侦听器的第一个匹配项。
|
ProgressivePromise<V> |
removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
为将来的每个听众删除第一个匹配项。
|
ProgressivePromise<V> |
setFailure(java.lang.Throwable cause)
将这个未来标志为失败并通知所有听众。
|
ProgressivePromise<V> |
setProgress(long progress, long total)
设置操作的当前进度并通知实现 GenericProgressiveFutureListener 的侦听器 。
|
ProgressivePromise<V> |
setSuccess(V result)
将这个未来标志为成功并通知所有听众。
|
ProgressivePromise<V> |
sync()
等待这个未来,直到完成,并且在这个未来失败的时候重新引发失败的原因。
|
ProgressivePromise<V> |
syncUninterruptibly()
等待这个未来,直到完成,并且在这个未来失败的时候重新引发失败的原因。
|
boolean |
tryProgress(long progress, long total)
尝试设置操作的当前进度并通知实施 GenericProgressiveFutureListener 的听众。
|
setUncancellable, tryFailure, trySuccess
await, await, awaitUninterruptibly, awaitUninterruptibly, cancel, cause, getNow, isCancellable, isSuccess
ProgressivePromise<V> setProgress(long progress, long total)
GenericProgressiveFutureListener
的侦听器 。
boolean tryProgress(long progress, long total)
GenericProgressiveFutureListener
的听众。
如果操作已完成或进度超出范围,则此方法false
返回false
。
ProgressivePromise<V> setSuccess(V result)
Promise
IllegalStateException
。
setSuccess
,界面
Promise<V>
ProgressivePromise<V> setFailure(java.lang.Throwable cause)
Promise
IllegalStateException
。
setFailure
,界面
Promise<V>
ProgressivePromise<V> addListener(GenericFutureListener<? extends Future<? super V>> listener)
Future
addListener
,界面
ProgressiveFuture<V>
addListener
,界面
Promise<V>
ProgressivePromise<V> addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Future
addListeners
,界面
ProgressiveFuture<V>
addListeners
接口
Promise<V>
ProgressivePromise<V> removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Future
removeListener
接口
ProgressiveFuture<V>
removeListener
,界面
Promise<V>
ProgressivePromise<V> removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Future
removeListeners
,界面
ProgressiveFuture<V>
removeListeners
,界面
Promise<V>
ProgressivePromise<V> await() throws java.lang.InterruptedException
Future
ProgressivePromise<V> awaitUninterruptibly()
Future
InterruptedException
并以静默方式丢弃它。
awaitUninterruptibly
在界面
ProgressiveFuture<V>
awaitUninterruptibly
,界面
Promise<V>
ProgressivePromise<V> sync() throws java.lang.InterruptedException
Future
ProgressivePromise<V> syncUninterruptibly()
Future
syncUninterruptibly
,界面
ProgressiveFuture<V>
syncUninterruptibly
,界面
Promise<V>
Copyright © 2008–2018 The Netty Project. All rights reserved.