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.channel.epoll |
Optimized transport for linux which uses EPOLL Edge-Triggered Mode
for maximal performance.
|
io.netty.channel.group |
A channel registry which helps a user maintain the list of open
Channel s and perform bulk operations on them. |
io.netty.channel.pool |
Implementations and API for
Channel pools. |
io.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
io.netty.handler.timeout |
Adds support for read and write timeout and idle connection notification
using a
Timer . |
io.netty.util.concurrent |
Utility classes for concurrent / async tasks.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelFutureListener
Listens to the result of a
ChannelFuture . |
interface |
ChannelProgressiveFutureListener
An
EventListener listener which will be called once the sending task associated with future is
being transferred. |
Modifier and Type | Class and Description |
---|---|
class |
ChannelPromiseAggregator
Deprecated.
Use
PromiseCombiner
Class which is used to consolidate multiple channel futures into one, by
listening to the individual futures and producing an aggregated result
(success/failure) when all futures have completed. |
class |
ChannelPromiseNotifier
ChannelFutureListener implementation which takes other
ChannelPromise (s) and notifies them on completion. |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
ChannelFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressivePromise |
DefaultChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressiveFuture |
ChannelProgressiveFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressivePromise |
ChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
CompleteChannelFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
ChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DefaultChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
VoidChannelPromise |
VoidChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
ChannelFuture.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelProgressivePromise |
DefaultChannelProgressivePromise.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelProgressiveFuture |
ChannelProgressiveFuture.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelProgressivePromise |
ChannelProgressivePromise.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelFuture |
CompleteChannelFuture.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
ChannelPromise.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
DefaultChannelPromise.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
VoidChannelPromise |
VoidChannelPromise.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelFuture |
ChannelFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressivePromise |
DefaultChannelProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressiveFuture |
ChannelProgressiveFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressivePromise |
ChannelProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
CompleteChannelFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
ChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DefaultChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
VoidChannelPromise |
VoidChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
ChannelFuture.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelProgressivePromise |
DefaultChannelProgressivePromise.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelProgressiveFuture |
ChannelProgressiveFuture.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelProgressivePromise |
ChannelProgressivePromise.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelFuture |
CompleteChannelFuture.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
ChannelPromise.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
DefaultChannelPromise.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
VoidChannelPromise |
VoidChannelPromise.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
Modifier and Type | Class and Description |
---|---|
private class |
AbstractEpollStreamChannel.SpliceInChannelTask |
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelGroupFutureListener
Listens to the result of a
ChannelGroupFuture . |
Modifier and Type | Method and Description |
---|---|
DefaultChannelGroupFuture |
DefaultChannelGroupFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelGroupFuture |
ChannelGroupFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
DefaultChannelGroupFuture |
DefaultChannelGroupFuture.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelGroupFuture |
ChannelGroupFuture.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
DefaultChannelGroupFuture |
DefaultChannelGroupFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelGroupFuture |
ChannelGroupFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
DefaultChannelGroupFuture |
DefaultChannelGroupFuture.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelGroupFuture |
ChannelGroupFuture.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
Modifier and Type | Class and Description |
---|---|
private class |
FixedChannelPool.AcquireListener |
private class |
FixedChannelPool.AcquireTask |
Modifier and Type | Class and Description |
---|---|
private static class |
SpdySessionHandler.ClosingChannelFutureListener |
Modifier and Type | Class and Description |
---|---|
private class |
WriteTimeoutHandler.WriteTimeoutTask |
Modifier and Type | Interface and Description |
---|---|
interface |
FutureListener<V>
A subtype of
GenericFutureListener that hides type parameter for convenience. |
interface |
GenericProgressiveFutureListener<F extends ProgressiveFuture<?>> |
Modifier and Type | Class and Description |
---|---|
class |
PromiseAggregator<V,F extends Future<V>>
Deprecated.
Use
PromiseCombiner
GenericFutureListener implementation which consolidates multiple Future s
into one, by listening to individual Future s and producing an aggregated result
(success/failure) when all Future s have completed. |
class |
PromiseNotifier<V,F extends Future<V>>
GenericFutureListener implementation which takes other Promise s
and notifies them on completion. |
class |
UnaryPromiseNotifier<T> |
Modifier and Type | Field and Description |
---|---|
private GenericFutureListener<Future<?>> |
PromiseCombiner.listener |
private GenericFutureListener<? extends Future<?>>[] |
DefaultFutureListeners.listeners |
Modifier and Type | Method and Description |
---|---|
GenericFutureListener<? extends Future<?>>[] |
DefaultFutureListeners.listeners() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultFutureListeners.add(GenericFutureListener<? extends Future<?>> l) |
Promise<V> |
DefaultPromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
ProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
Promise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
DefaultProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
Future.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Adds the specified listener to this future.
|
ProgressiveFuture<V> |
ProgressiveFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
CompleteFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
private void |
DefaultPromise.addListener0(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
DefaultPromise.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
ProgressivePromise<V> |
ProgressivePromise.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Promise<V> |
Promise.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
ProgressivePromise<V> |
DefaultProgressivePromise.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Future<V> |
Future.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Adds the specified listeners to this future.
|
ProgressiveFuture<V> |
ProgressiveFuture.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Future<V> |
CompleteFuture.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
protected static void |
DefaultPromise.notifyListener(EventExecutor eventExecutor,
Future<?> future,
GenericFutureListener<?> listener)
Notify a listener that a future has completed.
|
private static void |
DefaultPromise.notifyListener0(Future future,
GenericFutureListener l) |
private static void |
DefaultPromise.notifyListenerWithStackOverFlowProtection(EventExecutor executor,
Future<?> future,
GenericFutureListener<?> listener)
The logic in this method should be identical to
DefaultPromise.notifyListeners() but
cannot share code because the listener(s) cannot be cached for an instance of DefaultPromise since the
listener(s) may be changed and is protected by a synchronized operation. |
void |
DefaultFutureListeners.remove(GenericFutureListener<? extends Future<?>> l) |
Promise<V> |
DefaultPromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
ProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
Promise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
DefaultProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
Future.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Removes the first occurrence of the specified listener from this future.
|
ProgressiveFuture<V> |
ProgressiveFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
CompleteFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
private void |
DefaultPromise.removeListener0(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
DefaultPromise.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
ProgressivePromise<V> |
ProgressivePromise.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Promise<V> |
Promise.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
ProgressivePromise<V> |
DefaultProgressivePromise.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Future<V> |
Future.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Removes the first occurrence for each of the listeners from this future.
|
ProgressiveFuture<V> |
ProgressiveFuture.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Future<V> |
CompleteFuture.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Constructor and Description |
---|
DefaultFutureListeners(GenericFutureListener<? extends Future<?>> first,
GenericFutureListener<? extends Future<?>> second) |
DefaultFutureListeners(GenericFutureListener<? extends Future<?>> first,
GenericFutureListener<? extends Future<?>> second) |