Package | Description |
---|---|
io.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
io.netty.util.concurrent |
Utility classes for concurrent / async tasks.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelProgressivePromise
Special
ChannelPromise which will be notified once the associated bytes is transferring. |
Modifier and Type | Class and Description |
---|---|
class |
DefaultChannelProgressivePromise
The default
ChannelProgressivePromise implementation. |
Modifier and Type | Class and Description |
---|---|
class |
DefaultProgressivePromise<V> |
Modifier and Type | Method and Description |
---|---|
ProgressivePromise<V> |
DefaultProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
ProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
DefaultProgressivePromise.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
ProgressivePromise<V> |
ProgressivePromise.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
ProgressivePromise<V> |
DefaultProgressivePromise.await() |
ProgressivePromise<V> |
ProgressivePromise.await() |
ProgressivePromise<V> |
DefaultProgressivePromise.awaitUninterruptibly() |
ProgressivePromise<V> |
ProgressivePromise.awaitUninterruptibly() |
<V> ProgressivePromise<V> |
AbstractEventExecutor.newProgressivePromise() |
<V> ProgressivePromise<V> |
ImmediateEventExecutor.newProgressivePromise() |
<V> ProgressivePromise<V> |
EventExecutor.newProgressivePromise()
Create a new
ProgressivePromise . |
<V> ProgressivePromise<V> |
UnorderedThreadPoolEventExecutor.newProgressivePromise() |
ProgressivePromise<V> |
DefaultProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
ProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
DefaultProgressivePromise.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
ProgressivePromise<V> |
ProgressivePromise.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
ProgressivePromise<V> |
DefaultProgressivePromise.setFailure(Throwable cause) |
ProgressivePromise<V> |
ProgressivePromise.setFailure(Throwable cause) |
ProgressivePromise<V> |
DefaultProgressivePromise.setProgress(long progress,
long total) |
ProgressivePromise<V> |
ProgressivePromise.setProgress(long progress,
long total)
Sets the current progress of the operation and notifies the listeners that implement
GenericProgressiveFutureListener . |
ProgressivePromise<V> |
DefaultProgressivePromise.setSuccess(V result) |
ProgressivePromise<V> |
ProgressivePromise.setSuccess(V result) |
ProgressivePromise<V> |
DefaultProgressivePromise.sync() |
ProgressivePromise<V> |
ProgressivePromise.sync() |
ProgressivePromise<V> |
DefaultProgressivePromise.syncUninterruptibly() |
ProgressivePromise<V> |
ProgressivePromise.syncUninterruptibly() |
Copyright © 2008–2024 The Netty Project. All rights reserved.