Package | Description |
---|---|
io.netty.bootstrap |
The helper classes with fluent API which enable an easy implementation of
typical client side and server side channel initialization.
|
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.embedded |
A virtual
Channel that helps wrapping a series of handlers to
unit test the handlers or use them in non-I/O context. |
io.netty.channel.local |
A virtual transport that enables the communication between the two
parties in the same virtual machine.
|
io.netty.channel.nio |
NIO-based channel
API implementation - recommended for a large number of connections (>= 1000).
|
io.netty.channel.oio |
Old blocking I/O based channel API implementation - recommended for
a small number of connections (< 1000).
|
io.netty.channel.sctp |
Abstract SCTP socket interfaces which extend the core channel API.
|
io.netty.channel.sctp.nio |
NIO-based SCTP Channel
API implementation - recommended for a large number of connections (>= 1000).
|
io.netty.channel.sctp.oio |
Old blocking I/O based SCTP channel API implementation - recommended for
a small number of connections (< 1000).
|
io.netty.channel.socket |
Abstract TCP and UDP socket interfaces which extend the core channel API.
|
io.netty.channel.socket.nio |
NIO-based socket channel
API implementation - recommended for a large number of connections (>= 1000).
|
io.netty.channel.socket.oio |
Old blocking I/O based socket channel API implementation - recommended for
a small number of connections (< 1000).
|
io.netty.handler.codec |
Extensible decoder and its common implementations which deal with the
packet fragmentation and reassembly issue found in a stream-based transport
such as TCP/IP.
|
io.netty.handler.codec.compression | |
io.netty.handler.codec.http |
Encoder, decoder and their related message types for HTTP.
|
io.netty.handler.codec.http.cors |
This package contains Cross Origin Resource Sharing (CORS) related classes.
|
io.netty.handler.codec.http.websocketx |
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
|
io.netty.handler.codec.http.websocketx.extensions |
Encoder, decoder, handshakers to handle
WebSocket Extensions.
|
io.netty.handler.codec.http2 |
Handlers for sending and receiving HTTP/2 frames.
|
io.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
io.netty.handler.flush |
Package to control flush behavior.
|
io.netty.handler.logging |
Logs the I/O events for debugging purpose.
|
io.netty.handler.proxy |
Adds support for client connections via proxy protocols such as
SOCKS and
HTTP CONNECT tunneling
|
io.netty.handler.ssl |
SSL ·
TLS implementation based on
SSLEngine |
io.netty.handler.stream |
Writes very large data stream asynchronously neither spending a lot of
memory nor getting
OutOfMemoryError . |
io.netty.handler.timeout |
Adds support for read and write timeout and idle connection notification
using a
Timer . |
io.netty.handler.traffic |
Implementation of a Traffic Shaping Handler and Dynamic Statistics.
|
io.netty.resolver.dns |
An alternative to Java's built-in domain name lookup mechanism that resolves a domain name asynchronously,
which supports the queries of an arbitrary DNS record type as well.
|
Modifier and Type | Class and Description |
---|---|
(package private) static class |
AbstractBootstrap.PendingRegistrationPromise |
Modifier and Type | Method and Description |
---|---|
private static void |
AbstractBootstrap.doBind0(ChannelFuture regFuture,
Channel channel,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
private static void |
Bootstrap.doConnect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise connectPromise) |
private ChannelFuture |
Bootstrap.doResolveAndConnect0(Channel channel,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
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 |
---|---|
(package private) static class |
AbstractChannel.CloseFuture |
class |
DefaultChannelProgressivePromise
The default
ChannelProgressivePromise implementation. |
class |
DefaultChannelPromise
The default
ChannelPromise implementation. |
(package private) class |
VoidChannelPromise |
Modifier and Type | Field and Description |
---|---|
private ChannelPromise |
ChannelFlushPromiseNotifier.DefaultFlushCheckpoint.future |
(package private) ChannelPromise |
ChannelOutboundBuffer.Entry.promise |
private ChannelPromise |
PendingWriteQueue.PendingWrite.promise |
private ChannelPromise |
AbstractChannelHandlerContext.AbstractWriteTask.promise |
Modifier and Type | Method and Description |
---|---|
ChannelPromise |
ChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DefaultChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
ChannelPromise.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
DefaultChannelPromise.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
ChannelPromise.await() |
ChannelPromise |
DefaultChannelPromise.await() |
ChannelPromise |
ChannelPromise.awaitUninterruptibly() |
ChannelPromise |
DefaultChannelPromise.awaitUninterruptibly() |
ChannelPromise |
AbstractChannel.newPromise() |
ChannelPromise |
DefaultChannelPipeline.newPromise() |
ChannelPromise |
ChannelOutboundInvoker.newPromise()
Return a new
ChannelPromise . |
ChannelPromise |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.newPromise() |
ChannelPromise |
AbstractChannelHandlerContext.newPromise() |
ChannelPromise |
ChannelFlushPromiseNotifier.FlushCheckpoint.promise() |
ChannelPromise |
ChannelFlushPromiseNotifier.DefaultFlushCheckpoint.promise() |
ChannelPromise |
DefaultChannelPromise.promise() |
ChannelPromise |
PendingWriteQueue.remove()
Removes a pending write operation and release it's message via
ReferenceCountUtil.safeRelease(Object) . |
ChannelPromise |
ChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DefaultChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
ChannelPromise.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
DefaultChannelPromise.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
AbstractChannel.CloseFuture.setFailure(java.lang.Throwable cause) |
ChannelPromise |
ChannelPromise.setFailure(java.lang.Throwable cause) |
ChannelPromise |
DefaultChannelPromise.setFailure(java.lang.Throwable cause) |
ChannelPromise |
AbstractChannel.CloseFuture.setSuccess() |
ChannelPromise |
ChannelPromise.setSuccess() |
ChannelPromise |
DefaultChannelPromise.setSuccess() |
ChannelPromise |
ChannelPromise.setSuccess(java.lang.Void result) |
ChannelPromise |
DefaultChannelPromise.setSuccess(java.lang.Void result) |
ChannelPromise |
ChannelPromise.sync() |
ChannelPromise |
DefaultChannelPromise.sync() |
ChannelPromise |
ChannelPromise.syncUninterruptibly() |
ChannelPromise |
DefaultChannelPromise.syncUninterruptibly() |
ChannelPromise |
VoidChannelPromise.unvoid() |
ChannelPromise |
ChannelPromise.unvoid()
|
ChannelPromise |
DefaultChannelPromise.unvoid() |
ChannelPromise |
AbstractChannel.voidPromise() |
ChannelPromise |
AbstractChannel.AbstractUnsafe.voidPromise() |
ChannelPromise |
Channel.Unsafe.voidPromise()
Return a special ChannelPromise which can be reused and passed to the operations in
Channel.Unsafe . |
ChannelPromise |
DefaultChannelPipeline.voidPromise() |
ChannelPromise |
ChannelOutboundInvoker.voidPromise()
Return a special ChannelPromise which can be reused for different operations.
|
ChannelPromise |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.voidPromise() |
ChannelPromise |
AbstractChannelHandlerContext.voidPromise() |
Modifier and Type | Method and Description |
---|---|
void |
CoalescingBufferQueue.add(ByteBuf buf,
ChannelPromise promise)
Add a buffer to the end of the queue and associate a promise with it that should be completed when
all the buffers bytes have been consumed from the queue and written.
|
ChannelFlushPromiseNotifier |
ChannelFlushPromiseNotifier.add(ChannelPromise promise,
int pendingDataSize)
Deprecated.
|
ChannelFlushPromiseNotifier |
ChannelFlushPromiseNotifier.add(ChannelPromise promise,
long pendingDataSize)
Add a
ChannelPromise to this ChannelFlushPromiseNotifier which will be notified after the given
pendingDataSize was reached. |
void |
PendingWriteQueue.add(java.lang.Object msg,
ChannelPromise promise)
Add the given
msg and ChannelPromise . |
void |
ChannelOutboundBuffer.addMessage(java.lang.Object msg,
int size,
ChannelPromise promise)
Add given message to this
ChannelOutboundBuffer . |
void |
DefaultChannelPipeline.HeadContext.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Called once a bind operation is made.
|
void |
ChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.bind(java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.bind(java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
Channel.Unsafe.bind(java.net.SocketAddress localAddress,
ChannelPromise promise)
|
ChannelFuture |
DefaultChannelPipeline.bind(java.net.SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.bind(java.net.SocketAddress localAddress,
ChannelPromise promise)
Request to bind to the given
SocketAddress and notify the ChannelFuture once the operation
completes, either because the operation was successful or because of an error. |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.bind(java.net.SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
AbstractChannelHandlerContext.bind(java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
DefaultChannelPipeline.HeadContext.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a close operation is made.
|
void |
ChannelOutboundHandlerAdapter.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.close(ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.close(ChannelPromise promise) |
void |
Channel.Unsafe.close(ChannelPromise promise)
Close the
Channel of the ChannelPromise and notify the ChannelPromise once the
operation was complete. |
ChannelFuture |
DefaultChannelPipeline.close(ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.close(ChannelPromise promise)
Request to close the
Channel and notify the ChannelFuture once the operation completes,
either because the operation was successful or because of
an error. |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.close(ChannelPromise promise) |
ChannelFuture |
AbstractChannelHandlerContext.close(ChannelPromise promise) |
private void |
AbstractChannel.AbstractUnsafe.close(ChannelPromise promise,
java.lang.Throwable cause,
java.nio.channels.ClosedChannelException closeCause,
boolean notify) |
void |
DefaultChannelPipeline.HeadContext.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Called once a connect operation is made.
|
void |
ChannelOutboundHandlerAdapter.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.connect(java.net.SocketAddress remoteAddress,
ChannelPromise promise) |
ChannelFuture |
DefaultChannelPipeline.connect(java.net.SocketAddress remoteAddress,
ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.connect(java.net.SocketAddress remoteAddress,
ChannelPromise promise)
Request to connect to the given
SocketAddress and notify the ChannelFuture once the operation
completes, either because the operation was successful or because of an error. |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.connect(java.net.SocketAddress remoteAddress,
ChannelPromise promise) |
ChannelFuture |
AbstractChannelHandlerContext.connect(java.net.SocketAddress remoteAddress,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
Channel.Unsafe.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
|
ChannelFuture |
DefaultChannelPipeline.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Request to connect to the given
SocketAddress while bind to the localAddress and notify the
ChannelFuture once the operation completes, either because the operation was successful or because of
an error. |
void |
AbstractServerChannel.DefaultServerUnsafe.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
AbstractChannelHandlerContext.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
DefaultChannelPipeline.HeadContext.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a deregister operation is made from the current registered
EventLoop . |
void |
ChannelOutboundHandlerAdapter.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.deregister(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.deregister(ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.deregister(ChannelPromise promise) |
void |
Channel.Unsafe.deregister(ChannelPromise promise)
Deregister the
Channel of the ChannelPromise from EventLoop and notify the
ChannelPromise once the operation was complete. |
ChannelFuture |
DefaultChannelPipeline.deregister(ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.deregister(ChannelPromise promise)
Request to deregister from the previous assigned
EventExecutor and notify the
ChannelFuture once the operation completes, either because the operation was successful or because of
an error. |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.deregister(ChannelPromise promise) |
ChannelFuture |
AbstractChannelHandlerContext.deregister(ChannelPromise promise) |
private void |
AbstractChannel.AbstractUnsafe.deregister(ChannelPromise promise,
boolean fireChannelInactive) |
void |
DefaultChannelPipeline.HeadContext.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a disconnect operation is made.
|
void |
ChannelOutboundHandlerAdapter.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.disconnect(ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.disconnect(ChannelPromise promise) |
void |
Channel.Unsafe.disconnect(ChannelPromise promise)
Disconnect the
Channel of the ChannelFuture and notify the ChannelPromise once the
operation was complete. |
ChannelFuture |
DefaultChannelPipeline.disconnect(ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.disconnect(ChannelPromise promise)
Request to disconnect from the remote peer and notify the
ChannelFuture once the operation completes,
either because the operation was successful or because of an error. |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.disconnect(ChannelPromise promise) |
ChannelFuture |
AbstractChannelHandlerContext.disconnect(ChannelPromise promise) |
private void |
AbstractChannel.AbstractUnsafe.doClose0(ChannelPromise promise) |
protected boolean |
AbstractChannel.AbstractUnsafe.ensureOpen(ChannelPromise promise) |
protected static void |
AbstractChannelHandlerContext.AbstractWriteTask.init(AbstractChannelHandlerContext.AbstractWriteTask task,
AbstractChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
private void |
AbstractChannelHandlerContext.invokeBind(java.net.SocketAddress localAddress,
ChannelPromise promise) |
private void |
AbstractChannelHandlerContext.invokeClose(ChannelPromise promise) |
private void |
AbstractChannelHandlerContext.invokeConnect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
private void |
AbstractChannelHandlerContext.invokeDeregister(ChannelPromise promise) |
private void |
AbstractChannelHandlerContext.invokeDisconnect(ChannelPromise promise) |
private void |
AbstractChannelHandlerContext.invokeWrite(java.lang.Object msg,
ChannelPromise promise) |
private void |
AbstractChannelHandlerContext.invokeWrite0(java.lang.Object msg,
ChannelPromise promise) |
private void |
AbstractChannelHandlerContext.invokeWriteAndFlush(java.lang.Object msg,
ChannelPromise promise) |
private boolean |
AbstractChannelHandlerContext.isNotValidPromise(ChannelPromise promise,
boolean allowVoidPromise) |
private static AbstractChannelHandlerContext.WriteTask |
AbstractChannelHandlerContext.WriteTask.newInstance(AbstractChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
private static AbstractChannelHandlerContext.WriteAndFlushTask |
AbstractChannelHandlerContext.WriteAndFlushTask.newInstance(AbstractChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
(package private) static PendingWriteQueue.PendingWrite |
PendingWriteQueue.PendingWrite.newInstance(java.lang.Object msg,
int size,
ChannelPromise promise) |
(package private) static ChannelOutboundBuffer.Entry |
ChannelOutboundBuffer.Entry.newInstance(java.lang.Object msg,
int size,
long total,
ChannelPromise promise) |
private static void |
AbstractChannelHandlerContext.notifyOutboundHandlerException(java.lang.Throwable cause,
ChannelPromise promise) |
ChannelFuture |
ThreadPerChannelEventLoop.register(Channel channel,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
SingleThreadEventLoop.register(Channel channel,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(Channel channel,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
EventLoopGroup.register(Channel channel,
ChannelPromise promise)
Deprecated.
Use
EventLoopGroup.register(ChannelPromise) instead. |
ChannelFuture |
MultithreadEventLoopGroup.register(Channel channel,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
ThreadPerChannelEventLoop.register(ChannelPromise promise) |
ChannelFuture |
SingleThreadEventLoop.register(ChannelPromise promise) |
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(ChannelPromise promise) |
ChannelFuture |
EventLoopGroup.register(ChannelPromise promise)
|
ChannelFuture |
MultithreadEventLoopGroup.register(ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.register(EventLoop eventLoop,
ChannelPromise promise) |
void |
Channel.Unsafe.register(EventLoop eventLoop,
ChannelPromise promise)
Register the
Channel of the ChannelPromise and notify
the ChannelFuture once the registration was complete. |
private void |
AbstractChannel.AbstractUnsafe.register0(ChannelPromise promise) |
ByteBuf |
CoalescingBufferQueue.remove(int bytes,
ChannelPromise aggregatePromise)
Remove a
ByteBuf from the queue with the specified number of bytes. |
private static void |
AbstractChannelHandlerContext.safeExecute(EventExecutor executor,
java.lang.Runnable runnable,
ChannelPromise promise,
java.lang.Object msg) |
private static void |
ChannelOutboundBuffer.safeFail(ChannelPromise promise,
java.lang.Throwable cause) |
private static void |
PendingWriteQueue.safeFail(ChannelPromise promise,
java.lang.Throwable cause) |
protected void |
AbstractChannel.AbstractUnsafe.safeSetFailure(ChannelPromise promise,
java.lang.Throwable cause)
Marks the specified
promise as failure. |
protected void |
AbstractChannel.AbstractUnsafe.safeSetSuccess(ChannelPromise promise)
Marks the specified
promise as success. |
private static void |
ChannelOutboundBuffer.safeSuccess(ChannelPromise promise) |
protected void |
AbstractChannelHandlerContext.AbstractWriteTask.write(AbstractChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
AbstractChannelHandlerContext.WriteAndFlushTask.write(AbstractChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
DefaultChannelPipeline.HeadContext.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
ChannelOutboundHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Called once a write operation is made.
|
void |
ChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
private void |
AbstractChannelHandlerContext.write(java.lang.Object msg,
boolean flush,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.write(java.lang.Object msg,
ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.write(java.lang.Object msg,
ChannelPromise promise) |
void |
Channel.Unsafe.write(java.lang.Object msg,
ChannelPromise promise)
Schedules a write operation.
|
ChannelFuture |
DefaultChannelPipeline.write(java.lang.Object msg,
ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.write(java.lang.Object msg,
ChannelPromise promise)
Request to write a message via this
ChannelHandlerContext through the ChannelPipeline . |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.write(java.lang.Object msg,
ChannelPromise promise) |
ChannelFuture |
AbstractChannelHandlerContext.write(java.lang.Object msg,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.writeAndFlush(java.lang.Object msg,
ChannelPromise promise) |
ChannelFuture |
DefaultChannelPipeline.writeAndFlush(java.lang.Object msg,
ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.writeAndFlush(java.lang.Object msg,
ChannelPromise promise)
Shortcut for call
ChannelOutboundInvoker.write(Object, ChannelPromise) and ChannelOutboundInvoker.flush() . |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.writeAndFlush(java.lang.Object msg,
ChannelPromise promise) |
ChannelFuture |
AbstractChannelHandlerContext.writeAndFlush(java.lang.Object msg,
ChannelPromise promise) |
Constructor and Description |
---|
ChannelPromiseAggregator(ChannelPromise aggregatePromise)
Deprecated.
|
ChannelPromiseNotifier(boolean logNotifyFailure,
ChannelPromise... promises)
Create a new instance
|
ChannelPromiseNotifier(ChannelPromise... promises)
Create a new instance
|
DefaultFlushCheckpoint(long checkpoint,
ChannelPromise future) |
Modifier and Type | Method and Description |
---|---|
private ChannelFuture |
EmbeddedChannel.checkException(ChannelPromise promise)
Checks for the presence of an
Exception . |
ChannelFuture |
EmbeddedChannel.close(ChannelPromise promise) |
void |
EmbeddedChannel.DefaultUnsafe.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
EmbeddedChannel.disconnect(ChannelPromise promise) |
private ChannelFuture |
EmbeddedChannel.flushInbound(boolean recordException,
ChannelPromise promise) |
ChannelFuture |
EmbeddedEventLoop.register(Channel channel,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
EmbeddedEventLoop.register(ChannelPromise promise) |
ChannelFuture |
EmbeddedChannel.writeOneInbound(java.lang.Object msg,
ChannelPromise promise)
Writes one message to the inbound of this
Channel and does not flush it. |
ChannelFuture |
EmbeddedChannel.writeOneOutbound(java.lang.Object msg,
ChannelPromise promise)
Writes one message to the outbound of this
Channel and does not flush it. |
Modifier and Type | Field and Description |
---|---|
private ChannelPromise |
LocalChannel.connectPromise |
Modifier and Type | Method and Description |
---|---|
void |
LocalChannel.LocalUnsafe.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
Modifier and Type | Field and Description |
---|---|
private ChannelPromise |
AbstractNioChannel.connectPromise
The future of the current connection attempt.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractNioChannel.AbstractNioUnsafe.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
private void |
AbstractNioChannel.AbstractNioUnsafe.fulfillConnectPromise(ChannelPromise promise,
boolean wasActive) |
private void |
AbstractNioChannel.AbstractNioUnsafe.fulfillConnectPromise(ChannelPromise promise,
java.lang.Throwable cause) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractOioChannel.DefaultOioUnsafe.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
SctpChannel.bindAddress(java.net.InetAddress localAddress,
ChannelPromise promise)
Bind a address to the already bound channel to enable multi-homing.
|
ChannelFuture |
SctpServerChannel.bindAddress(java.net.InetAddress localAddress,
ChannelPromise promise)
Bind a address to the already bound channel to enable multi-homing.
|
ChannelFuture |
SctpChannel.unbindAddress(java.net.InetAddress localAddress,
ChannelPromise promise)
Unbind the address from channel's multi-homing address list.
|
ChannelFuture |
SctpServerChannel.unbindAddress(java.net.InetAddress localAddress,
ChannelPromise promise)
Unbind the address from channel's multi-homing address list.
|
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
NioSctpChannel.bindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
NioSctpServerChannel.bindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
NioSctpChannel.unbindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
NioSctpServerChannel.unbindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
OioSctpServerChannel.bindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
OioSctpChannel.bindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
OioSctpServerChannel.unbindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
OioSctpChannel.unbindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
DatagramChannel.block(java.net.InetAddress multicastAddress,
java.net.InetAddress sourceToBlock,
ChannelPromise future)
Block the given sourceToBlock address for the given multicastAddress and notifies the
ChannelFuture once
the operation completes. |
ChannelFuture |
DatagramChannel.block(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress sourceToBlock,
ChannelPromise future)
Block the given sourceToBlock address for the given multicastAddress on the given networkInterface and notifies
the
ChannelFuture once the operation completes. |
ChannelFuture |
DatagramChannel.joinGroup(java.net.InetAddress multicastAddress,
ChannelPromise future)
Joins a multicast group and notifies the
ChannelFuture once the operation completes. |
ChannelFuture |
DatagramChannel.joinGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source,
ChannelPromise future)
Joins the specified multicast group at the specified interface and notifies the
ChannelFuture
once the operation completes. |
ChannelFuture |
DatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface,
ChannelPromise future)
Joins the specified multicast group at the specified interface and notifies the
ChannelFuture
once the operation completes. |
ChannelFuture |
DatagramChannel.leaveGroup(java.net.InetAddress multicastAddress,
ChannelPromise future)
Leaves a multicast group and notifies the
ChannelFuture once the operation completes. |
ChannelFuture |
DatagramChannel.leaveGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source,
ChannelPromise future)
Leave the specified multicast group at the specified interface using the specified source and notifies
the
ChannelFuture once the operation completes. |
ChannelFuture |
DatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface,
ChannelPromise future)
Leaves a multicast group on a specified local interface and notifies the
ChannelFuture once the
operation completes. |
ChannelFuture |
DuplexChannel.shutdown(ChannelPromise promise)
Will shutdown the input and output sides of this channel.
|
ChannelFuture |
DuplexChannel.shutdownInput(ChannelPromise promise)
Will shutdown the input and notify
ChannelPromise . |
ChannelFuture |
DuplexChannel.shutdownOutput(ChannelPromise promise)
Will shutdown the output and notify
ChannelPromise . |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
NioDatagramChannel.block(java.net.InetAddress multicastAddress,
java.net.InetAddress sourceToBlock,
ChannelPromise promise)
Block the given sourceToBlock address for the given multicastAddress
|
ChannelFuture |
NioDatagramChannel.block(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress sourceToBlock,
ChannelPromise promise)
Block the given sourceToBlock address for the given multicastAddress on the given networkInterface
|
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress,
ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source,
ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface,
ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress,
ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source,
ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface,
ChannelPromise promise) |
ChannelFuture |
NioSocketChannel.shutdown(ChannelPromise promise) |
private void |
NioSocketChannel.shutdown0(ChannelPromise promise) |
ChannelFuture |
NioSocketChannel.shutdownInput(ChannelPromise promise) |
private void |
NioSocketChannel.shutdownInput0(ChannelPromise promise) |
ChannelFuture |
NioSocketChannel.shutdownOutput(ChannelPromise promise) |
private void |
NioSocketChannel.shutdownOutput0(ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
OioDatagramChannel.block(java.net.InetAddress multicastAddress,
java.net.InetAddress sourceToBlock,
ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.block(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress sourceToBlock,
ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress,
ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source,
ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface,
ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress,
ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source,
ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface,
ChannelPromise promise) |
ChannelFuture |
OioSocketChannel.shutdown(ChannelPromise promise) |
private void |
OioSocketChannel.shutdown0(ChannelPromise promise) |
ChannelFuture |
OioSocketChannel.shutdownInput(ChannelPromise promise) |
private void |
OioSocketChannel.shutdownInput0(ChannelPromise promise) |
ChannelFuture |
OioSocketChannel.shutdownOutput(ChannelPromise promise) |
private void |
OioSocketChannel.shutdownOutput0(ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
DatagramPacketEncoder.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
DatagramPacketEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DatagramPacketEncoder.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
DatagramPacketEncoder.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DatagramPacketEncoder.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
MessageToMessageCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
MessageToMessageEncoder.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
MessageToByteEncoder.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
ByteToMessageCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
Bzip2Encoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JdkZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
Bzip2Encoder.close(ChannelPromise promise)
Close this
Bzip2Encoder and so finish the encoding. |
abstract ChannelFuture |
ZlibEncoder.close(ChannelPromise promise)
Close this
ZlibEncoder and so finish the encoding. |
ChannelFuture |
JdkZlibEncoder.close(ChannelPromise promise) |
ChannelFuture |
JZlibEncoder.close(ChannelPromise promise) |
private ChannelFuture |
Bzip2Encoder.finishEncode(ChannelHandlerContext ctx,
ChannelPromise promise) |
private ChannelFuture |
JdkZlibEncoder.finishEncode(ChannelHandlerContext ctx,
ChannelPromise promise) |
private ChannelFuture |
JZlibEncoder.finishEncode(ChannelHandlerContext ctx,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
HttpClientUpgradeHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
HttpClientUpgradeHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
HttpClientUpgradeHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
HttpClientUpgradeHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
HttpClientUpgradeHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
HttpServerKeepAliveHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
HttpClientUpgradeHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
CorsHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
WebSocketServerHandshaker00.close(Channel channel,
CloseWebSocketFrame frame,
ChannelPromise promise)
Echo back the closing frame
|
ChannelFuture |
WebSocketClientHandshaker.close(Channel channel,
CloseWebSocketFrame frame,
ChannelPromise promise)
Performs the closing handshake
|
ChannelFuture |
WebSocketServerHandshaker.close(Channel channel,
CloseWebSocketFrame frame,
ChannelPromise promise)
Performs the closing handshake
|
ChannelFuture |
WebSocketClientHandshaker.handshake(Channel channel,
ChannelPromise promise)
Begins the opening handshake
|
ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel,
FullHttpRequest req,
HttpHeaders responseHeaders,
ChannelPromise promise)
Performs the opening handshake
When call this method you MUST NOT retain the
FullHttpRequest which is passed in. |
ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel,
HttpRequest req,
HttpHeaders responseHeaders,
ChannelPromise promise)
Performs the opening handshake
When call this method you MUST NOT retain the
HttpRequest which is passed in. |
ChannelFuture |
WebSocketClientHandshaker.processHandshake(Channel channel,
HttpResponse response,
ChannelPromise promise)
Process the opening handshake initiated by
WebSocketClientHandshaker.handshake(io.netty.channel.Channel) }. |
static ChannelFuture |
WebSocketServerHandshakerFactory.sendUnsupportedVersionResponse(Channel channel,
ChannelPromise promise)
Return that we need cannot not support the web socket version
|
Modifier and Type | Method and Description |
---|---|
void |
WebSocketClientExtensionHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
WebSocketServerExtensionHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Class and Description |
---|---|
(package private) static class |
Http2CodecUtil.SimpleChannelPromiseAggregator
Provides the ability to associate the outcome of multiple
ChannelPromise
objects into a single ChannelPromise object. |
Modifier and Type | Field and Description |
---|---|
(package private) ChannelPromise |
StreamBufferingEncoder.Frame.promise |
private ChannelPromise |
Http2ConnectionHandler.ClosingChannelFutureListener.promise |
protected ChannelPromise |
DefaultHttp2ConnectionEncoder.FlowControlledBase.promise |
private ChannelPromise |
Http2CodecUtil.SimpleChannelPromiseAggregator.promise |
Modifier and Type | Method and Description |
---|---|
ChannelPromise |
Http2CodecUtil.SimpleChannelPromiseAggregator.doneAllocatingPromises()
Signify that no more
Http2CodecUtil.SimpleChannelPromiseAggregator.newPromise() allocations will be made. |
ChannelPromise |
Http2CodecUtil.SimpleChannelPromiseAggregator.newPromise()
Allocate a new promise which will be used to aggregate the overall success of this promise aggregator.
|
ChannelPromise |
Http2CodecUtil.SimpleChannelPromiseAggregator.setFailure(java.lang.Throwable cause)
Fail this object if it has not already been failed.
|
private ChannelPromise |
Http2CodecUtil.SimpleChannelPromiseAggregator.setPromise() |
ChannelPromise |
Http2CodecUtil.SimpleChannelPromiseAggregator.setSuccess(java.lang.Void result) |
Modifier and Type | Method and Description |
---|---|
void |
Http2ConnectionHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
Http2ConnectionHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
Http2ConnectionHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
AbstractHttp2StreamChannel.Unsafe.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
private void |
Http2FrameCodec.consumeBytes(int streamId,
int bytes,
ChannelPromise promise) |
void |
Http2ConnectionHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
Http2ConnectionHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
private void |
Http2ConnectionHandler.doGracefulShutdown(ChannelHandlerContext ctx,
ChannelFuture future,
ChannelPromise promise) |
ChannelFuture |
Http2ConnectionHandler.goAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
Http2LifecycleManager.goAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise)
Prevents the peer from creating streams and close the connection if
errorCode is not
Http2Error.NO_ERROR . |
private ChannelFuture |
Http2ConnectionHandler.resetStream(ChannelHandlerContext ctx,
Http2Stream stream,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2ConnectionHandler.resetStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2LifecycleManager.resetStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise)
Ensure the stream identified by
streamId is reset. |
private ChannelFuture |
Http2ConnectionHandler.resetUnknownStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise)
Sends a
RST_STREAM frame even if we don't know about the stream. |
void |
Http2FrameCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Processes all
Http2Frame s. |
void |
Http2ConnectionHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
HttpToHttp2ConnectionHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Handles conversion of
HttpMessage and HttpContent to HTTP/2 frames. |
ChannelFuture |
DefaultHttp2FrameWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
Http2DataWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise)
Writes a
DATA frame to the remote endpoint. |
ChannelFuture |
DefaultHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise)
Generic write method for any HTTP/2 frame.
|
ChannelFuture |
DecoratingHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
Http2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise)
Writes the given data to the internal
Http2FrameWriter without performing any
state checks on the connection/stream. |
ChannelFuture |
Http2OutboundFrameLogger.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
(package private) void |
Http2MultiplexCodec.writeFromStreamChannel(java.lang.Object msg,
ChannelPromise promise,
boolean flush) |
private void |
Http2MultiplexCodec.writeFromStreamChannel0(java.lang.Object msg,
boolean flush,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise)
Writes a GO_AWAY frame to the remote endpoint.
|
ChannelFuture |
DecoratingHttp2FrameWriter.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
private void |
Http2FrameCodec.writeGoAwayFrame(Http2GoAwayFrame frame,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise)
Writes a HEADERS frame to the remote endpoint.
|
ChannelFuture |
DecoratingHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
ChannelPromise promise)
Writes a HEADERS frame with priority specified to the remote endpoint.
|
ChannelFuture |
DecoratingHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
ChannelPromise promise) |
private void |
Http2FrameCodec.writeHeadersFrame(Http2HeadersFrame headersFrame,
ChannelPromise promise) |
private ChannelFuture |
DefaultHttp2FrameWriter.writeHeadersInternal(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
boolean hasPriority,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise)
Writes a PING frame to the remote endpoint.
|
ChannelFuture |
DecoratingHttp2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise)
Writes a PRIORITY frame to the remote endpoint.
|
ChannelFuture |
DecoratingHttp2FrameWriter.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise)
Writes a PUSH_PROMISE frame to the remote endpoint.
|
ChannelFuture |
DecoratingHttp2FrameWriter.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise)
Writes a RST_STREAM frame to the remote endpoint.
|
ChannelFuture |
DecoratingHttp2FrameWriter.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise)
Writes a SETTINGS frame to the remote endpoint.
|
ChannelFuture |
DecoratingHttp2FrameWriter.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise)
Writes a SETTINGS acknowledgment to the remote endpoint.
|
ChannelFuture |
DecoratingHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
private void |
Http2FrameCodec.writeStreamFrame(Http2StreamFrame frame,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise)
Writes a WINDOW_UPDATE frame to the remote endpoint.
|
ChannelFuture |
DecoratingHttp2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
Constructor and Description |
---|
ClosingChannelFutureListener(ChannelHandlerContext ctx,
ChannelPromise promise) |
ClosingChannelFutureListener(ChannelHandlerContext ctx,
ChannelPromise promise,
long timeout,
java.util.concurrent.TimeUnit unit) |
DataFrame(ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
FlowControlledBase(Http2Stream stream,
int padding,
boolean endOfStream,
ChannelPromise promise) |
FlowControlledData(Http2Stream stream,
ByteBuf buf,
int padding,
boolean endOfStream,
ChannelPromise promise) |
FlowControlledHeaders(Http2Stream stream,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
ChannelPromise promise) |
Frame(ChannelPromise promise) |
HeadersFrame(Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
ChannelPromise promise) |
SimpleChannelPromiseAggregator(ChannelPromise promise,
Channel c,
EventExecutor e) |
Modifier and Type | Field and Description |
---|---|
(package private) ChannelPromise |
SpdySession.PendingWrite.promise |
private ChannelPromise |
SpdySessionHandler.ClosingChannelFutureListener.promise |
Modifier and Type | Method and Description |
---|---|
void |
SpdyFrameCodec.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SpdySessionHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdyFrameCodec.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdyFrameCodec.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SpdyFrameCodec.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdyFrameCodec.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
private void |
SpdySessionHandler.handleOutboundMessage(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
private void |
SpdySessionHandler.sendGoAwayFrame(ChannelHandlerContext ctx,
ChannelPromise future) |
void |
SpdySessionHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
SpdyFrameCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Constructor and Description |
---|
ClosingChannelFutureListener(ChannelHandlerContext ctx,
ChannelPromise promise) |
PendingWrite(SpdyDataFrame spdyDataFrame,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
FlushConsolidationHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
FlushConsolidationHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
LoggingHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
LoggingHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
LoggingHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
private void |
ProxyHandler.addPendingWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
ProxyHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ProxyHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
private static void |
SslHandler.addCloseListener(ChannelFuture future,
ChannelPromise promise) |
void |
SslHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
AbstractSniHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SslHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
AbstractSniHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
SslHandler.close(ChannelPromise promise)
Deprecated.
|
private void |
SslHandler.closeOutboundAndChannel(ChannelHandlerContext ctx,
ChannelPromise promise,
boolean disconnect) |
void |
SslHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
AbstractSniHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SslHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
AbstractSniHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
AbstractSniHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
private void |
SslHandler.finishWrap(ChannelHandlerContext ctx,
ByteBuf out,
ChannelPromise promise,
boolean inUnwrap,
boolean needUnwrap) |
private void |
SslHandler.flush(ChannelHandlerContext ctx,
ChannelPromise promise) |
private void |
SslHandler.safeClose(ChannelHandlerContext ctx,
ChannelFuture flushFuture,
ChannelPromise promise) |
void |
SslHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
AbstractSniHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Field and Description |
---|---|
(package private) ChannelPromise |
ChunkedWriteHandler.PendingWrite.promise |
Modifier and Type | Method and Description |
---|---|
void |
ChunkedWriteHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Constructor and Description |
---|
PendingWrite(java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Field and Description |
---|---|
private ChannelPromise |
WriteTimeoutHandler.WriteTimeoutTask.promise |
Modifier and Type | Method and Description |
---|---|
private void |
WriteTimeoutHandler.scheduleTimeout(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
IdleStateHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
WriteTimeoutHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Constructor and Description |
---|
WriteTimeoutTask(ChannelHandlerContext ctx,
ChannelPromise promise) |
Modifier and Type | Field and Description |
---|---|
(package private) ChannelPromise |
GlobalChannelTrafficShapingHandler.ToSend.promise |
(package private) ChannelPromise |
ChannelTrafficShapingHandler.ToSend.promise |
(package private) ChannelPromise |
GlobalTrafficShapingHandler.ToSend.promise |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long delay,
ChannelPromise promise)
Deprecated.
|
protected void |
GlobalChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long writedelay,
long now,
ChannelPromise promise) |
(package private) void |
ChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long delay,
long now,
ChannelPromise promise) |
(package private) abstract void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long delay,
long now,
ChannelPromise promise) |
(package private) void |
GlobalTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long writedelay,
long now,
ChannelPromise promise) |
void |
GlobalChannelTrafficShapingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
AbstractTrafficShapingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Constructor and Description |
---|
ToSend(long delay,
java.lang.Object toSend,
ChannelPromise promise) |
ToSend(long delay,
java.lang.Object toSend,
long size,
ChannelPromise promise) |
ToSend(long delay,
java.lang.Object toSend,
long size,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
DnsQueryContext.query(ChannelPromise writePromise) |
(package private) Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query0(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
DnsRecord[] additionals,
ChannelPromise writePromise,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise) |
private void |
DnsQueryContext.sendQuery(DnsQuery query,
ChannelPromise writePromise) |
private void |
DnsQueryContext.writeQuery(DnsQuery query,
ChannelPromise writePromise) |