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.group |
A channel registry which helps a user maintain the list of open
Channel s and perform bulk operations on them. |
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.pool |
Implementations and API for
Channel pools. |
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.compression | |
io.netty.handler.codec.http.websocketx |
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
|
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.ipfilter |
Package to filter IP addresses (allow/deny).
|
io.netty.handler.ssl |
SSL ·
TLS implementation based on
SSLEngine |
io.netty.handler.timeout |
Adds support for read and write timeout and idle connection notification
using a
Timer . |
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 |
---|---|
ChannelFuture |
AbstractBootstrap.bind()
Create a new
Channel and bind it. |
ChannelFuture |
AbstractBootstrap.bind(java.net.InetAddress inetHost,
int inetPort)
Create a new
Channel and bind it. |
ChannelFuture |
AbstractBootstrap.bind(int inetPort)
Create a new
Channel and bind it. |
ChannelFuture |
AbstractBootstrap.bind(java.net.SocketAddress localAddress)
Create a new
Channel and bind it. |
ChannelFuture |
AbstractBootstrap.bind(java.lang.String inetHost,
int inetPort)
Create a new
Channel and bind it. |
ChannelFuture |
Bootstrap.connect()
Connect a
Channel to the remote peer. |
ChannelFuture |
Bootstrap.connect(java.net.InetAddress inetHost,
int inetPort)
Connect a
Channel to the remote peer. |
ChannelFuture |
Bootstrap.connect(java.net.SocketAddress remoteAddress)
Connect a
Channel to the remote peer. |
ChannelFuture |
Bootstrap.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
Connect a
Channel to the remote peer. |
ChannelFuture |
Bootstrap.connect(java.lang.String inetHost,
int inetPort)
Connect a
Channel to the remote peer. |
private ChannelFuture |
AbstractBootstrap.doBind(java.net.SocketAddress localAddress) |
private ChannelFuture |
Bootstrap.doResolveAndConnect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress) |
private ChannelFuture |
Bootstrap.doResolveAndConnect0(Channel channel,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
(package private) ChannelFuture |
AbstractBootstrap.initAndRegister() |
ChannelFuture |
AbstractBootstrap.register()
|
Modifier and Type | Method and Description |
---|---|
private static void |
AbstractBootstrap.doBind0(ChannelFuture regFuture,
Channel channel,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelProgressiveFuture
An special
ChannelFuture which is used to indicate the FileRegion transfer progress |
interface |
ChannelProgressivePromise
Special
ChannelPromise which will be notified once the associated bytes is transferring. |
interface |
ChannelPromise
Special
ChannelFuture which is writable. |
Modifier and Type | Class and Description |
---|---|
(package private) static class |
AbstractChannel.CloseFuture |
(package private) class |
CompleteChannelFuture
A skeletal
ChannelFuture implementation which represents a
ChannelFuture which has been completed already. |
class |
DefaultChannelProgressivePromise
The default
ChannelProgressivePromise implementation. |
class |
DefaultChannelPromise
The default
ChannelPromise implementation. |
(package private) class |
FailedChannelFuture
The
CompleteChannelFuture which is failed already. |
(package private) class |
SucceededChannelFuture
The
CompleteChannelFuture which is succeeded already. |
(package private) class |
VoidChannelPromise |
Modifier and Type | Field and Description |
---|---|
private ChannelFuture |
AbstractChannelHandlerContext.succeededFuture |
private ChannelFuture |
DefaultChannelPipeline.succeededFuture |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
CompleteChannelFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
ChannelFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
CompleteChannelFuture.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelFuture |
ChannelFuture.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelFuture |
CompleteChannelFuture.await() |
ChannelFuture |
ChannelFuture.await() |
ChannelFuture |
CompleteChannelFuture.awaitUninterruptibly() |
ChannelFuture |
ChannelFuture.awaitUninterruptibly() |
ChannelFuture |
AbstractChannelHandlerContext.bind(java.net.SocketAddress localAddress) |
ChannelFuture |
ChannelOutboundInvoker.bind(java.net.SocketAddress localAddress)
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 |
DefaultChannelPipeline.bind(java.net.SocketAddress localAddress) |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.bind(java.net.SocketAddress localAddress) |
ChannelFuture |
AbstractChannel.bind(java.net.SocketAddress localAddress) |
ChannelFuture |
AbstractChannelHandlerContext.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 |
DefaultChannelPipeline.bind(java.net.SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.bind(java.net.SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.bind(java.net.SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
AbstractChannelHandlerContext.close() |
ChannelFuture |
ChannelOutboundInvoker.close()
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 |
DefaultChannelPipeline.close() |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.close() |
ChannelFuture |
AbstractChannel.close() |
ChannelFuture |
AbstractChannelHandlerContext.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 |
DefaultChannelPipeline.close(ChannelPromise promise) |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.close(ChannelPromise promise) |
ChannelFuture |
AbstractChannel.close(ChannelPromise promise) |
ChannelFuture |
Channel.closeFuture()
Returns the
ChannelFuture which will be notified when this
channel is closed. |
ChannelFuture |
AbstractChannel.closeFuture() |
ChannelFuture |
AbstractChannelHandlerContext.connect(java.net.SocketAddress remoteAddress) |
ChannelFuture |
ChannelOutboundInvoker.connect(java.net.SocketAddress remoteAddress)
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 |
DefaultChannelPipeline.connect(java.net.SocketAddress remoteAddress) |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.connect(java.net.SocketAddress remoteAddress) |
ChannelFuture |
AbstractChannel.connect(java.net.SocketAddress remoteAddress) |
ChannelFuture |
AbstractChannelHandlerContext.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 |
DefaultChannelPipeline.connect(java.net.SocketAddress remoteAddress,
ChannelPromise promise) |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.connect(java.net.SocketAddress remoteAddress,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.connect(java.net.SocketAddress remoteAddress,
ChannelPromise promise) |
ChannelFuture |
AbstractChannelHandlerContext.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress) |
ChannelFuture |
ChannelOutboundInvoker.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
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. |
ChannelFuture |
DefaultChannelPipeline.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress) |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress) |
ChannelFuture |
AbstractChannel.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress) |
ChannelFuture |
AbstractChannelHandlerContext.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. |
ChannelFuture |
DefaultChannelPipeline.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 |
AbstractChannel.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
AbstractChannelHandlerContext.deregister() |
ChannelFuture |
ChannelOutboundInvoker.deregister()
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 |
DefaultChannelPipeline.deregister() |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.deregister() |
ChannelFuture |
AbstractChannel.deregister() |
ChannelFuture |
AbstractChannelHandlerContext.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 |
DefaultChannelPipeline.deregister(ChannelPromise promise) |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.deregister(ChannelPromise promise) |
ChannelFuture |
AbstractChannel.deregister(ChannelPromise promise) |
ChannelFuture |
AbstractChannelHandlerContext.disconnect() |
ChannelFuture |
ChannelOutboundInvoker.disconnect()
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 |
DefaultChannelPipeline.disconnect() |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.disconnect() |
ChannelFuture |
AbstractChannel.disconnect() |
ChannelFuture |
AbstractChannelHandlerContext.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 |
DefaultChannelPipeline.disconnect(ChannelPromise promise) |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.disconnect(ChannelPromise promise) |
ChannelFuture |
AbstractChannel.disconnect(ChannelPromise promise) |
ChannelFuture |
AbstractChannelHandlerContext.newFailedFuture(java.lang.Throwable cause) |
ChannelFuture |
ChannelOutboundInvoker.newFailedFuture(java.lang.Throwable cause)
Create a new
ChannelFuture which is marked as failed already. |
ChannelFuture |
DefaultChannelPipeline.newFailedFuture(java.lang.Throwable cause) |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.newFailedFuture(java.lang.Throwable cause) |
ChannelFuture |
AbstractChannel.newFailedFuture(java.lang.Throwable cause) |
ChannelFuture |
AbstractChannelHandlerContext.newSucceededFuture() |
ChannelFuture |
ChannelOutboundInvoker.newSucceededFuture()
Create a new
ChannelFuture which is marked as succeeded already. |
ChannelFuture |
DefaultChannelPipeline.newSucceededFuture() |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.newSucceededFuture() |
ChannelFuture |
AbstractChannel.newSucceededFuture() |
ChannelFuture |
SingleThreadEventLoop.register(Channel channel) |
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(Channel channel) |
ChannelFuture |
EventLoopGroup.register(Channel channel)
|
ChannelFuture |
MultithreadEventLoopGroup.register(Channel channel) |
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) |
ChannelFuture |
PendingWriteQueue.removeAndWrite()
Removes a pending write operation and performs it via
ChannelOutboundInvoker.write(Object, ChannelPromise) . |
ChannelFuture |
PendingWriteQueue.removeAndWriteAll()
Remove all pending write operation and performs them via
ChannelOutboundInvoker.write(Object, ChannelPromise) . |
ChannelFuture |
CompleteChannelFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
ChannelFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
CompleteChannelFuture.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelFuture |
ChannelFuture.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelFuture |
CompleteChannelFuture.sync() |
ChannelFuture |
FailedChannelFuture.sync() |
ChannelFuture |
ChannelFuture.sync() |
ChannelFuture |
CompleteChannelFuture.syncUninterruptibly() |
ChannelFuture |
FailedChannelFuture.syncUninterruptibly() |
ChannelFuture |
ChannelFuture.syncUninterruptibly() |
ChannelFuture |
AbstractChannelHandlerContext.write(java.lang.Object msg) |
ChannelFuture |
ChannelOutboundInvoker.write(java.lang.Object msg)
Request to write a message via this
ChannelHandlerContext through the ChannelPipeline . |
ChannelFuture |
DefaultChannelPipeline.write(java.lang.Object msg) |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.write(java.lang.Object msg) |
ChannelFuture |
AbstractChannel.write(java.lang.Object msg) |
ChannelFuture |
AbstractChannelHandlerContext.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 |
DefaultChannelPipeline.write(java.lang.Object msg,
ChannelPromise promise) |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.write(java.lang.Object msg,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.write(java.lang.Object msg,
ChannelPromise promise) |
ChannelFuture |
AbstractChannelHandlerContext.writeAndFlush(java.lang.Object msg) |
ChannelFuture |
ChannelOutboundInvoker.writeAndFlush(java.lang.Object msg)
Shortcut for call
ChannelOutboundInvoker.write(Object) and ChannelOutboundInvoker.flush() . |
ChannelFuture |
DefaultChannelPipeline.writeAndFlush(java.lang.Object msg) |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.writeAndFlush(java.lang.Object msg) |
ChannelFuture |
AbstractChannel.writeAndFlush(java.lang.Object msg) |
ChannelFuture |
AbstractChannelHandlerContext.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 |
DefaultChannelPipeline.writeAndFlush(java.lang.Object msg,
ChannelPromise promise) |
ChannelFuture |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.writeAndFlush(java.lang.Object msg,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.writeAndFlush(java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
private void |
CoalescingBufferQueue.releaseAndCompleteAll(ChannelFuture future) |
Modifier and Type | Method and Description |
---|---|
private ChannelFuture |
EmbeddedChannel.checkException(ChannelPromise promise)
Checks for the presence of an
Exception . |
ChannelFuture |
EmbeddedChannel.close() |
ChannelFuture |
EmbeddedChannel.close(ChannelPromise promise) |
ChannelFuture |
EmbeddedChannel.disconnect() |
ChannelFuture |
EmbeddedChannel.disconnect(ChannelPromise promise) |
private ChannelFuture |
EmbeddedChannel.flushInbound(boolean recordException,
ChannelPromise promise) |
ChannelFuture |
EmbeddedEventLoop.register(Channel channel) |
ChannelFuture |
EmbeddedEventLoop.register(Channel channel,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
EmbeddedEventLoop.register(ChannelPromise promise) |
ChannelFuture |
EmbeddedChannel.writeOneInbound(java.lang.Object msg)
Writes one message to the inbound of this
Channel and does not flush it. |
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)
Writes one message to the outbound 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 | Method and Description |
---|---|
private void |
EmbeddedChannel.recordException(ChannelFuture future) |
Modifier and Type | Field and Description |
---|---|
private static java.util.Iterator<ChannelFuture> |
VoidChannelGroupFuture.EMPTY |
private java.util.Map<Channel,ChannelFuture> |
DefaultChannelGroupFuture.futures |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
VoidChannelGroupFuture.find(Channel channel) |
ChannelFuture |
DefaultChannelGroupFuture.find(Channel channel) |
ChannelFuture |
ChannelGroupFuture.find(Channel channel)
Returns the
ChannelFuture of the individual I/O operation which
is associated with the specified Channel . |
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<ChannelFuture> |
VoidChannelGroupFuture.iterator() |
java.util.Iterator<ChannelFuture> |
DefaultChannelGroupFuture.iterator() |
java.util.Iterator<ChannelFuture> |
ChannelGroupFuture.iterator()
Returns the
Iterator that enumerates all ChannelFuture s
which are associated with this future. |
Constructor and Description |
---|
DefaultChannelGroupFuture(ChannelGroup group,
java.util.Collection<ChannelFuture> futures,
EventExecutor executor)
Creates a new instance.
|
DefaultChannelGroupFuture(ChannelGroup group,
java.util.Map<Channel,ChannelFuture> futures,
EventExecutor executor) |
Modifier and Type | Method and Description |
---|---|
protected abstract ChannelFuture |
AbstractNioByteChannel.shutdownInput()
Shutdown the input side of the channel.
|
Modifier and Type | Method and Description |
---|---|
protected abstract ChannelFuture |
AbstractOioByteChannel.shutdownInput()
Shutdown the input side of this channel.
|
Modifier and Type | Method and Description |
---|---|
protected ChannelFuture |
SimpleChannelPool.connectChannel(Bootstrap bs)
Bootstrap a new
Channel . |
Modifier and Type | Method and Description |
---|---|
private void |
SimpleChannelPool.notifyConnect(ChannelFuture future,
Promise<Channel> promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
SctpChannel.bindAddress(java.net.InetAddress localAddress)
Bind a address to the already bound channel to enable multi-homing.
|
ChannelFuture |
SctpServerChannel.bindAddress(java.net.InetAddress localAddress)
Bind a address to the already bound channel to enable multi-homing.
|
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)
Unbind the address from channel's multi-homing address list.
|
ChannelFuture |
SctpServerChannel.unbindAddress(java.net.InetAddress localAddress)
Unbind the address from channel's multi-homing address list.
|
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) |
ChannelFuture |
NioSctpServerChannel.bindAddress(java.net.InetAddress localAddress) |
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) |
ChannelFuture |
NioSctpServerChannel.unbindAddress(java.net.InetAddress localAddress) |
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 |
OioSctpChannel.bindAddress(java.net.InetAddress localAddress) |
ChannelFuture |
OioSctpServerChannel.bindAddress(java.net.InetAddress localAddress) |
ChannelFuture |
OioSctpChannel.bindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
OioSctpServerChannel.bindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
OioSctpChannel.unbindAddress(java.net.InetAddress localAddress) |
ChannelFuture |
OioSctpServerChannel.unbindAddress(java.net.InetAddress localAddress) |
ChannelFuture |
OioSctpChannel.unbindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
OioSctpServerChannel.unbindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
DatagramChannel.block(java.net.InetAddress multicastAddress,
java.net.InetAddress sourceToBlock)
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.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)
Block the given sourceToBlock address for the given multicastAddress on the given networkInterface 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)
Joins a multicast group 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)
Joins the specified multicast group at the specified interface 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)
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)
Leaves a multicast group 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)
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.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)
Leaves a multicast group on a specified local interface 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()
Will shutdown the input and output sides of this channel.
|
ChannelFuture |
DuplexChannel.shutdown(ChannelPromise promise)
Will shutdown the input and output sides of this channel.
|
ChannelFuture |
DuplexChannel.shutdownInput() |
ChannelFuture |
DuplexChannel.shutdownInput(ChannelPromise promise)
Will shutdown the input and notify
ChannelPromise . |
ChannelFuture |
DuplexChannel.shutdownOutput() |
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)
Block the given sourceToBlock address for the given multicastAddress
|
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)
Block the given sourceToBlock address for the given multicastAddress on the given networkInterface
|
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) |
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress,
ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source) |
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) |
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface,
ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress,
ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source) |
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) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface,
ChannelPromise promise) |
ChannelFuture |
NioSocketChannel.shutdown() |
ChannelFuture |
NioSocketChannel.shutdown(ChannelPromise promise) |
ChannelFuture |
NioSocketChannel.shutdownInput() |
ChannelFuture |
NioSocketChannel.shutdownInput(ChannelPromise promise) |
ChannelFuture |
NioSocketChannel.shutdownOutput() |
ChannelFuture |
NioSocketChannel.shutdownOutput(ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
OioDatagramChannel.block(java.net.InetAddress multicastAddress,
java.net.InetAddress sourceToBlock) |
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) |
ChannelFuture |
OioDatagramChannel.block(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress sourceToBlock,
ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress,
ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source) |
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) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface,
ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress,
ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source) |
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) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface,
ChannelPromise promise) |
ChannelFuture |
OioSocketChannel.shutdown() |
ChannelFuture |
OioSocketChannel.shutdown(ChannelPromise promise) |
ChannelFuture |
OioSocketChannel.shutdownInput() |
ChannelFuture |
OioSocketChannel.shutdownInput(ChannelPromise promise) |
ChannelFuture |
OioSocketChannel.shutdownOutput() |
ChannelFuture |
OioSocketChannel.shutdownOutput(ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
JZlibEncoder.close() |
ChannelFuture |
JdkZlibEncoder.close() |
abstract ChannelFuture |
ZlibEncoder.close()
Close this
ZlibEncoder and so finish the encoding. |
ChannelFuture |
Bzip2Encoder.close()
Close this
Bzip2Encoder and so finish the encoding. |
ChannelFuture |
JZlibEncoder.close(ChannelPromise promise) |
ChannelFuture |
JdkZlibEncoder.close(ChannelPromise promise) |
abstract ChannelFuture |
ZlibEncoder.close(ChannelPromise promise)
Close this
ZlibEncoder and so finish the encoding. |
ChannelFuture |
Bzip2Encoder.close(ChannelPromise promise)
Close this
Bzip2Encoder and so finish the encoding. |
private ChannelFuture |
JZlibEncoder.finishEncode(ChannelHandlerContext ctx,
ChannelPromise promise) |
private ChannelFuture |
JdkZlibEncoder.finishEncode(ChannelHandlerContext ctx,
ChannelPromise promise) |
private ChannelFuture |
Bzip2Encoder.finishEncode(ChannelHandlerContext ctx,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
WebSocketClientHandshaker.close(Channel channel,
CloseWebSocketFrame frame)
Performs the closing handshake
|
ChannelFuture |
WebSocketServerHandshaker.close(Channel channel,
CloseWebSocketFrame frame)
Performs the closing handshake
|
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 |
WebSocketServerHandshaker00.close(Channel channel,
CloseWebSocketFrame frame,
ChannelPromise promise)
Echo back the closing frame
|
ChannelFuture |
WebSocketClientHandshaker.handshake(Channel channel)
Begins the opening handshake
|
ChannelFuture |
WebSocketClientHandshaker.handshake(Channel channel,
ChannelPromise promise)
Begins the opening handshake
|
ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel,
FullHttpRequest req)
Performs 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)
Performs the opening handshake.
|
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)
Process the opening handshake initiated by
WebSocketClientHandshaker.handshake(io.netty.channel.Channel) }. |
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)
Return that we need cannot not support the web socket version
|
static ChannelFuture |
WebSocketServerHandshakerFactory.sendUnsupportedVersionResponse(Channel channel,
ChannelPromise promise)
Return that we need cannot not support the web socket version
|
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 | Method and Description |
---|---|
ChannelFuture |
Http2StreamChannelBootstrap.connect()
Creates a new channel that will eventually map to a local/outbound HTTP/2 stream.
|
(package private) ChannelFuture |
Http2StreamChannelBootstrap.connect(int streamId)
Used by the
Http2MultiplexCodec to instantiate incoming/remotely-created streams. |
(package private) ChannelFuture |
Http2MultiplexCodec.createStreamChannel(Channel parentChannel,
EventLoopGroup group,
ChannelHandler handler,
java.util.Map<ChannelOption<?>,java.lang.Object> options,
java.util.Map<AttributeKey<?>,java.lang.Object> attrs,
int streamId) |
private ChannelFuture |
Http2ConnectionHandler.goAway(ChannelHandlerContext ctx,
Http2Exception cause)
Close the remote endpoint with with a
GO_AWAY frame. |
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 . |
ChannelFuture |
Http2ConnectionHandler.goAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
private ChannelFuture |
Http2ConnectionHandler.resetStream(ChannelHandlerContext ctx,
Http2Stream stream,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2LifecycleManager.resetStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise)
Ensure the stream identified by
streamId is reset. |
ChannelFuture |
Http2ConnectionHandler.resetStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
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. |
private ChannelFuture |
DefaultHttp2FrameWriter.writeContinuationFrames(ChannelHandlerContext ctx,
int streamId,
ByteBuf headerBlock,
int padding,
Http2CodecUtil.SimpleChannelPromiseAggregator promiseAggregator)
Writes as many continuation frames as needed until
padding and headerBlock are consumed. |
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 |
Http2OutboundFrameLogger.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 |
DecoratingHttp2FrameWriter.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 |
DefaultHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.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) |
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 |
DefaultHttp2FrameWriter.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.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 |
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 |
Http2OutboundFrameLogger.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 |
CompressorHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.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 |
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 |
Http2OutboundFrameLogger.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
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 |
CompressorHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
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 |
Http2OutboundFrameLogger.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 |
DefaultHttp2FrameWriter.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 |
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 |
DefaultHttp2FrameWriter.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 |
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 |
DefaultHttp2FrameWriter.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.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 |
DefaultHttp2FrameWriter.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.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 |
DefaultHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.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 |
DefaultHttp2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.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) |
Modifier and Type | Method and Description |
---|---|
private void |
Http2ConnectionHandler.checkCloseConnection(ChannelFuture future)
Closes the connection if the graceful shutdown process has completed.
|
private void |
Http2ConnectionHandler.closeConnectionOnError(ChannelHandlerContext ctx,
ChannelFuture future) |
void |
Http2LifecycleManager.closeStream(Http2Stream stream,
ChannelFuture future)
Closes and deactivates the given
stream . |
void |
Http2ConnectionHandler.closeStream(Http2Stream stream,
ChannelFuture future) |
void |
Http2LifecycleManager.closeStreamLocal(Http2Stream stream,
ChannelFuture future)
Closes the local side of the
stream . |
void |
Http2ConnectionHandler.closeStreamLocal(Http2Stream stream,
ChannelFuture future)
Closes the local side of the given stream.
|
void |
Http2LifecycleManager.closeStreamRemote(Http2Stream stream,
ChannelFuture future)
Closes the remote side of the
stream . |
void |
Http2ConnectionHandler.closeStreamRemote(Http2Stream stream,
ChannelFuture future)
Closes the remote side of the given stream.
|
private void |
Http2ConnectionHandler.doGracefulShutdown(ChannelHandlerContext ctx,
ChannelFuture future,
ChannelPromise promise) |
void |
Http2ConnectionHandler.ClosingChannelFutureListener.operationComplete(ChannelFuture sentGoAwayFuture) |
void |
Http2MultiplexCodec.Http2StreamChannel.operationComplete(ChannelFuture future) |
void |
DefaultHttp2ConnectionEncoder.FlowControlledBase.operationComplete(ChannelFuture future) |
private static void |
Http2ConnectionHandler.processGoAwayWriteResult(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelFuture future) |
private void |
Http2ConnectionHandler.processRstStreamWriteResult(ChannelHandlerContext ctx,
Http2Stream stream,
ChannelFuture future) |
Modifier and Type | Method and Description |
---|---|
private ChannelFuture |
SpdySessionHandler.sendGoAwayFrame(ChannelHandlerContext ctx,
SpdySessionStatus status) |
Modifier and Type | Method and Description |
---|---|
private void |
SpdySessionHandler.halfCloseStream(int streamId,
boolean remote,
ChannelFuture future) |
void |
SpdySessionHandler.ClosingChannelFutureListener.operationComplete(ChannelFuture sentGoAwayFuture) |
private void |
SpdySessionHandler.removeStream(int streamId,
ChannelFuture future) |
Modifier and Type | Method and Description |
---|---|
protected ChannelFuture |
AbstractRemoteAddressFilter.channelRejected(ChannelHandlerContext ctx,
T remoteAddress)
This method is called if
remoteAddress gets rejected by
AbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress) . |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
SslHandler.close()
Deprecated.
|
ChannelFuture |
SslHandler.close(ChannelPromise promise)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
private static void |
SslHandler.addCloseListener(ChannelFuture future,
ChannelPromise promise) |
private void |
SslHandler.safeClose(ChannelHandlerContext ctx,
ChannelFuture flushFuture,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
WriteTimeoutHandler.WriteTimeoutTask.operationComplete(ChannelFuture future) |
Modifier and Type | Method and Description |
---|---|
private void |
DnsQueryContext.onQueryWriteCompletion(ChannelFuture writeFuture) |
void |
TraceDnsQueryLifecycleObserver.queryWritten(java.net.InetSocketAddress dnsServerAddress,
ChannelFuture future) |
void |
DnsQueryLifecycleObserver.queryWritten(java.net.InetSocketAddress dnsServerAddress,
ChannelFuture future)
The query has been written.
|
void |
BiDnsQueryLifecycleObserver.queryWritten(java.net.InetSocketAddress dnsServerAddress,
ChannelFuture future) |
void |
NoopDnsQueryLifecycleObserver.queryWritten(java.net.InetSocketAddress dnsServerAddress,
ChannelFuture future) |