public class DefaultChannelPromise extends io.netty.util.concurrent.DefaultPromise<Void> implements ChannelPromise
ChannelPromise implementation. It is recommended to use ChannelOutboundInvoker.newPromise() to create
a new ChannelPromise rather than calling the constructor explicitly.| Constructor and Description |
|---|
DefaultChannelPromise(Channel channel)
Creates a new instance.
|
DefaultChannelPromise(Channel channel,
io.netty.util.concurrent.EventExecutor executor)
Creates a new instance.
|
| Modifier and Type | Method and Description |
|---|---|
ChannelPromise |
addListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener) |
ChannelPromise |
addListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>... listeners) |
ChannelPromise |
await() |
ChannelPromise |
awaitUninterruptibly() |
Channel |
channel()
Returns a channel where the I/O operation associated with this
future takes place.
|
protected void |
checkDeadLock() |
protected io.netty.util.concurrent.EventExecutor |
executor() |
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(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener) |
ChannelPromise |
removeListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>... listeners) |
ChannelPromise |
setFailure(Throwable cause) |
ChannelPromise |
setSuccess() |
ChannelPromise |
setSuccess(Void result) |
ChannelPromise |
sync() |
ChannelPromise |
syncUninterruptibly() |
boolean |
trySuccess() |
ChannelPromise |
unvoid()
|
await, await, awaitUninterruptibly, awaitUninterruptibly, cancel, cause, getNow, isCancellable, isCancelled, isDone, isSuccess, notifyListener, setUncancellable, toString, toStringBuilder, tryFailure, trySuccessclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitsetUncancellable, tryFailure, trySuccessawait, await, awaitUninterruptibly, awaitUninterruptibly, cancel, cause, getNow, isCancellable, isSuccessget, get, isCancelled, isDonepublic DefaultChannelPromise(Channel channel)
channel - the Channel associated with this futureprotected io.netty.util.concurrent.EventExecutor executor()
executor in class io.netty.util.concurrent.DefaultPromise<Void>public Channel channel()
ChannelFuturechannel in interface ChannelFuturechannel in interface ChannelPromisepublic ChannelPromise setSuccess()
setSuccess in interface ChannelPromisepublic ChannelPromise setSuccess(Void result)
setSuccess in interface ChannelPromisesetSuccess in interface io.netty.util.concurrent.Promise<Void>setSuccess in class io.netty.util.concurrent.DefaultPromise<Void>public boolean trySuccess()
trySuccess in interface ChannelPromisepublic ChannelPromise setFailure(Throwable cause)
setFailure in interface ChannelPromisesetFailure in interface io.netty.util.concurrent.Promise<Void>setFailure in class io.netty.util.concurrent.DefaultPromise<Void>public ChannelPromise addListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener)
addListener in interface ChannelFutureaddListener in interface ChannelPromiseaddListener in interface io.netty.util.concurrent.Promise<Void>addListener in class io.netty.util.concurrent.DefaultPromise<Void>public ChannelPromise addListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>... listeners)
addListeners in interface ChannelFutureaddListeners in interface ChannelPromiseaddListeners in interface io.netty.util.concurrent.Promise<Void>addListeners in class io.netty.util.concurrent.DefaultPromise<Void>public ChannelPromise removeListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener)
removeListener in interface ChannelFutureremoveListener in interface ChannelPromiseremoveListener in interface io.netty.util.concurrent.Promise<Void>removeListener in class io.netty.util.concurrent.DefaultPromise<Void>public ChannelPromise removeListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>... listeners)
removeListeners in interface ChannelFutureremoveListeners in interface ChannelPromiseremoveListeners in interface io.netty.util.concurrent.Promise<Void>removeListeners in class io.netty.util.concurrent.DefaultPromise<Void>public ChannelPromise sync() throws InterruptedException
sync in interface ChannelFuturesync in interface ChannelPromisesync in interface io.netty.util.concurrent.Promise<Void>sync in class io.netty.util.concurrent.DefaultPromise<Void>InterruptedExceptionpublic ChannelPromise syncUninterruptibly()
syncUninterruptibly in interface ChannelFuturesyncUninterruptibly in interface ChannelPromisesyncUninterruptibly in interface io.netty.util.concurrent.Promise<Void>syncUninterruptibly in class io.netty.util.concurrent.DefaultPromise<Void>public ChannelPromise await() throws InterruptedException
await in interface ChannelFutureawait in interface ChannelPromiseawait in interface io.netty.util.concurrent.Promise<Void>await in class io.netty.util.concurrent.DefaultPromise<Void>InterruptedExceptionpublic ChannelPromise awaitUninterruptibly()
awaitUninterruptibly in interface ChannelFutureawaitUninterruptibly in interface ChannelPromiseawaitUninterruptibly in interface io.netty.util.concurrent.Promise<Void>awaitUninterruptibly in class io.netty.util.concurrent.DefaultPromise<Void>public long flushCheckpoint()
public void flushCheckpoint(long checkpoint)
public ChannelPromise promise()
protected void checkDeadLock()
checkDeadLock in class io.netty.util.concurrent.DefaultPromise<Void>public ChannelPromise unvoid()
ChannelPromiseunvoid in interface ChannelPromisepublic boolean isVoid()
ChannelFuturetrue 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()isVoid in interface ChannelFutureCopyright © 2008–2019 The Netty Project. All rights reserved.