@UnstableApi public final class DelegatingChannelPromiseNotifier extends 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(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() |
boolean |
await(long timeoutMillis) |
boolean |
await(long timeout,
TimeUnit unit) |
ChannelPromise |
awaitUninterruptibly() |
boolean |
awaitUninterruptibly(long timeoutMillis) |
boolean |
awaitUninterruptibly(long timeout,
TimeUnit unit) |
boolean |
cancel(boolean mayInterruptIfRunning) |
Throwable |
cause() |
Channel |
channel()
Returns a channel where the I/O operation associated with this
future takes place.
|
Void |
get() |
Void |
get(long timeout,
TimeUnit unit) |
Void |
getNow() |
boolean |
isCancellable() |
boolean |
isCancelled() |
boolean |
isDone() |
boolean |
isSuccess() |
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()
|
void |
operationComplete(ChannelFuture future) |
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) |
boolean |
setUncancellable() |
ChannelPromise |
sync() |
ChannelPromise |
syncUninterruptibly() |
boolean |
tryFailure(Throwable cause) |
boolean |
trySuccess() |
boolean |
trySuccess(Void result) |
ChannelPromise |
unvoid()
|
public DelegatingChannelPromiseNotifier(ChannelPromise delegate)
public DelegatingChannelPromiseNotifier(ChannelPromise delegate, boolean logNotifyFailure)
public void operationComplete(ChannelFuture future) throws Exception
operationComplete in interface io.netty.util.concurrent.GenericFutureListener<ChannelFuture>Exceptionpublic Channel channel()
ChannelFuturechannel in interface ChannelFuturechannel in interface ChannelPromisepublic ChannelPromise setSuccess(Void result)
setSuccess in interface ChannelPromisesetSuccess in interface io.netty.util.concurrent.Promise<Void>public ChannelPromise setSuccess()
setSuccess in interface ChannelPromisepublic boolean trySuccess()
trySuccess in interface ChannelPromisepublic boolean trySuccess(Void result)
trySuccess in interface io.netty.util.concurrent.Promise<Void>public ChannelPromise setFailure(Throwable cause)
setFailure in interface ChannelPromisesetFailure in interface io.netty.util.concurrent.Promise<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>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>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>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>public boolean tryFailure(Throwable cause)
tryFailure in interface io.netty.util.concurrent.Promise<Void>public boolean setUncancellable()
setUncancellable in interface io.netty.util.concurrent.Promise<Void>public ChannelPromise await() throws InterruptedException
await in interface ChannelFutureawait in interface ChannelPromiseawait in interface io.netty.util.concurrent.Promise<Void>InterruptedExceptionpublic ChannelPromise awaitUninterruptibly()
awaitUninterruptibly in interface ChannelFutureawaitUninterruptibly in interface ChannelPromiseawaitUninterruptibly in interface io.netty.util.concurrent.Promise<Void>public 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 ChannelFuturepublic ChannelPromise unvoid()
ChannelPromiseunvoid in interface ChannelPromisepublic boolean await(long timeout,
TimeUnit unit)
throws InterruptedException
InterruptedExceptionpublic boolean await(long timeoutMillis)
throws InterruptedException
InterruptedExceptionpublic boolean awaitUninterruptibly(long timeout,
TimeUnit unit)
public boolean awaitUninterruptibly(long timeoutMillis)
public Void getNow()
public boolean cancel(boolean mayInterruptIfRunning)
public boolean isCancelled()
isCancelled in interface Future<Void>public Void get() throws InterruptedException, ExecutionException
get in interface Future<Void>InterruptedExceptionExecutionExceptionpublic Void get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
get in interface Future<Void>InterruptedExceptionExecutionExceptionTimeoutExceptionpublic ChannelPromise sync() throws InterruptedException
sync in interface ChannelFuturesync in interface ChannelPromisesync in interface io.netty.util.concurrent.Promise<Void>InterruptedExceptionpublic ChannelPromise syncUninterruptibly()
syncUninterruptibly in interface ChannelFuturesyncUninterruptibly in interface ChannelPromisesyncUninterruptibly in interface io.netty.util.concurrent.Promise<Void>public boolean isSuccess()
public boolean isCancellable()
public Throwable cause()
Copyright © 2008–2025 The Netty Project. All rights reserved.