public class DefaultChannelProgressivePromise extends DefaultProgressivePromise<Void> implements ChannelProgressivePromise
ChannelProgressivePromise implementation. It is recommended to use
ChannelOutboundInvoker.newProgressivePromise() to create a new ChannelProgressivePromise rather than calling the
constructor explicitly.| Constructor and Description |
|---|
DefaultChannelProgressivePromise(Channel channel)
Creates a new instance.
|
DefaultChannelProgressivePromise(Channel channel,
EventExecutor executor)
Creates a new instance.
|
| Modifier and Type | Method and Description |
|---|---|
ChannelProgressivePromise |
addListener(GenericFutureListener<? extends Future<? super Void>> listener)
Adds the specified listener to this future.
|
ChannelProgressivePromise |
addListeners(GenericFutureListener<? extends Future<? super Void>>... listeners)
Adds the specified listeners to this future.
|
ChannelProgressivePromise |
await()
Waits for this future to be completed.
|
ChannelProgressivePromise |
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()
|
ChannelProgressivePromise |
promise() |
ChannelProgressivePromise |
removeListener(GenericFutureListener<? extends Future<? super Void>> listener)
Removes the first occurrence of the specified listener from this future.
|
ChannelProgressivePromise |
removeListeners(GenericFutureListener<? extends Future<? super Void>>... listeners)
Removes the first occurrence for each of the listeners from this future.
|
ChannelProgressivePromise |
setFailure(Throwable cause)
Marks this future as a failure and notifies all
listeners.
|
ChannelProgressivePromise |
setProgress(long progress,
long total)
Sets the current progress of the operation and notifies the listeners that implement
GenericProgressiveFutureListener. |
ChannelProgressivePromise |
setSuccess() |
ChannelProgressivePromise |
setSuccess(Void result)
Marks this future as a success and notifies all
listeners.
|
ChannelProgressivePromise |
sync()
Waits for this future until it is done, and rethrows the cause of the failure if this future
failed.
|
ChannelProgressivePromise |
syncUninterruptibly()
Waits for this future until it is done, and rethrows the cause of the failure if this future
failed.
|
boolean |
trySuccess() |
ChannelProgressivePromise |
unvoid()
|
tryProgressawait, await, awaitUninterruptibly, awaitUninterruptibly, cancel, cause, getNow, isCancellable, isCancelled, isDone, isSuccess, notifyListener, setUncancellable, toString, toStringBuilder, tryFailure, trySuccessget, getclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waittryProgresssetUncancellable, tryFailure, trySuccessawait, await, awaitUninterruptibly, awaitUninterruptibly, cancel, cause, getNow, isCancellable, isSuccessget, get, isCancelled, isDonepublic DefaultChannelProgressivePromise(Channel channel)
channel - the Channel associated with this futurepublic DefaultChannelProgressivePromise(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 in class DefaultPromise<Void>public Channel channel()
ChannelFuturechannel in interface ChannelFuturechannel in interface ChannelPromisepublic ChannelProgressivePromise setSuccess()
setSuccess in interface ChannelProgressivePromisesetSuccess in interface ChannelPromisepublic ChannelProgressivePromise setSuccess(Void result)
PromiseIllegalStateException.setSuccess in interface ChannelProgressivePromisesetSuccess in interface ChannelPromisesetSuccess in interface ProgressivePromise<Void>setSuccess in interface Promise<Void>setSuccess in class DefaultProgressivePromise<Void>public boolean trySuccess()
trySuccess in interface ChannelPromisepublic ChannelProgressivePromise setFailure(Throwable cause)
PromiseIllegalStateException.setFailure in interface ChannelProgressivePromisesetFailure in interface ChannelPromisesetFailure in interface ProgressivePromise<Void>setFailure in interface Promise<Void>setFailure in class DefaultProgressivePromise<Void>public ChannelProgressivePromise setProgress(long progress, long total)
ProgressivePromiseGenericProgressiveFutureListener.setProgress in interface ChannelProgressivePromisesetProgress in interface ProgressivePromise<Void>setProgress in class DefaultProgressivePromise<Void>public ChannelProgressivePromise addListener(GenericFutureListener<? extends Future<? super Void>> listener)
FutureaddListener in interface ChannelFutureaddListener in interface ChannelProgressiveFutureaddListener in interface ChannelProgressivePromiseaddListener in interface ChannelPromiseaddListener in interface ProgressiveFuture<Void>addListener in interface ProgressivePromise<Void>addListener in interface Promise<Void>addListener in class DefaultProgressivePromise<Void>public ChannelProgressivePromise addListeners(GenericFutureListener<? extends Future<? super Void>>... listeners)
FutureaddListeners in interface ChannelFutureaddListeners in interface ChannelProgressiveFutureaddListeners in interface ChannelProgressivePromiseaddListeners in interface ChannelPromiseaddListeners in interface ProgressiveFuture<Void>addListeners in interface ProgressivePromise<Void>addListeners in interface Promise<Void>addListeners in class DefaultProgressivePromise<Void>public ChannelProgressivePromise removeListener(GenericFutureListener<? extends Future<? super Void>> listener)
FutureremoveListener in interface ChannelFutureremoveListener in interface ChannelProgressiveFutureremoveListener in interface ChannelProgressivePromiseremoveListener in interface ChannelPromiseremoveListener in interface ProgressiveFuture<Void>removeListener in interface ProgressivePromise<Void>removeListener in interface Promise<Void>removeListener in class DefaultProgressivePromise<Void>public ChannelProgressivePromise removeListeners(GenericFutureListener<? extends Future<? super Void>>... listeners)
FutureremoveListeners in interface ChannelFutureremoveListeners in interface ChannelProgressiveFutureremoveListeners in interface ChannelProgressivePromiseremoveListeners in interface ChannelPromiseremoveListeners in interface ProgressiveFuture<Void>removeListeners in interface ProgressivePromise<Void>removeListeners in interface Promise<Void>removeListeners in class DefaultProgressivePromise<Void>public ChannelProgressivePromise sync() throws InterruptedException
Futuresync in interface ChannelFuturesync in interface ChannelProgressiveFuturesync in interface ChannelProgressivePromisesync in interface ChannelPromisesync in interface ProgressiveFuture<Void>sync in interface ProgressivePromise<Void>sync in interface Promise<Void>sync in class DefaultProgressivePromise<Void>InterruptedExceptionpublic ChannelProgressivePromise syncUninterruptibly()
FuturesyncUninterruptibly in interface ChannelFuturesyncUninterruptibly in interface ChannelProgressiveFuturesyncUninterruptibly in interface ChannelProgressivePromisesyncUninterruptibly in interface ChannelPromisesyncUninterruptibly in interface ProgressiveFuture<Void>syncUninterruptibly in interface ProgressivePromise<Void>syncUninterruptibly in interface Promise<Void>syncUninterruptibly in class DefaultProgressivePromise<Void>public ChannelProgressivePromise await() throws InterruptedException
Futureawait in interface ChannelFutureawait in interface ChannelProgressiveFutureawait in interface ChannelProgressivePromiseawait in interface ChannelPromiseawait in interface ProgressiveFuture<Void>await in interface ProgressivePromise<Void>await in interface Promise<Void>await in class DefaultProgressivePromise<Void>InterruptedException - if the current thread was interruptedpublic ChannelProgressivePromise awaitUninterruptibly()
FutureInterruptedException and
discards it silently.awaitUninterruptibly in interface ChannelFutureawaitUninterruptibly in interface ChannelProgressiveFutureawaitUninterruptibly in interface ChannelProgressivePromiseawaitUninterruptibly in interface ChannelPromiseawaitUninterruptibly in interface ProgressiveFuture<Void>awaitUninterruptibly in interface ProgressivePromise<Void>awaitUninterruptibly in interface Promise<Void>awaitUninterruptibly in class DefaultProgressivePromise<Void>public long flushCheckpoint()
public void flushCheckpoint(long checkpoint)
public ChannelProgressivePromise promise()
protected void checkDeadLock()
checkDeadLock in class DefaultPromise<Void>public ChannelProgressivePromise unvoid()
ChannelPromiseunvoid in interface ChannelProgressivePromiseunvoid in interface ChannelPromisepublic boolean isVoid()
ChannelFuturetrue if this ChannelFuture is a void future and so not allow to call any of the
following methods:
isVoid in interface ChannelFutureCopyright © 2008–2017 The Netty Project. All rights reserved.