程序包 | 说明 |
---|---|
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.epoll |
Optimized transport for linux which uses EPOLL Edge-Triggered Mode
for maximal performance.
|
io.netty.channel.nio |
NIO-based channel
API implementation - recommended for a large 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.example.spdy.client |
This package contains an example SPDY HTTP client.
|
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.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 a
io.netty.channel.ChannelEvent for debugging purpose. |
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.
|
限定符和类型 | 接口和说明 |
---|---|
interface |
ChannelProgressivePromise
Special
ChannelPromise which will be notified once the associated bytes is transferring. |
限定符和类型 | 类和说明 |
---|---|
class |
DefaultChannelProgressivePromise
The default
ChannelProgressivePromise implementation. |
class |
DefaultChannelPromise
The default
ChannelPromise implementation. |
限定符和类型 | 方法和说明 |
---|---|
ChannelPromise |
DefaultChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
ChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DefaultChannelPromise.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
ChannelPromise.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
DefaultChannelPromise.await() |
ChannelPromise |
ChannelPromise.await() |
ChannelPromise |
DefaultChannelPromise.awaitUninterruptibly() |
ChannelPromise |
ChannelPromise.awaitUninterruptibly() |
ChannelPromise |
ChannelHandlerContext.newPromise()
Return a new
ChannelPromise . |
ChannelPromise |
Channel.newPromise()
Return a new
ChannelPromise . |
ChannelPromise |
AbstractChannel.newPromise() |
ChannelPromise |
DefaultChannelPromise.promise() |
ChannelPromise |
PendingWriteQueue.remove()
Removes a pending write operation and release it's message via
ReferenceCountUtil.safeRelease(Object) . |
ChannelPromise |
DefaultChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
ChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DefaultChannelPromise.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
ChannelPromise.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
DefaultChannelPromise.setFailure(java.lang.Throwable cause) |
ChannelPromise |
ChannelPromise.setFailure(java.lang.Throwable cause) |
ChannelPromise |
DefaultChannelPromise.setSuccess() |
ChannelPromise |
ChannelPromise.setSuccess() |
ChannelPromise |
DefaultChannelPromise.setSuccess(java.lang.Void result) |
ChannelPromise |
ChannelPromise.setSuccess(java.lang.Void result) |
ChannelPromise |
DefaultChannelPromise.sync() |
ChannelPromise |
ChannelPromise.sync() |
ChannelPromise |
DefaultChannelPromise.syncUninterruptibly() |
ChannelPromise |
ChannelPromise.syncUninterruptibly() |
ChannelPromise |
ChannelHandlerContext.voidPromise()
Return a special ChannelPromise which can be reused for different operations.
|
ChannelPromise |
Channel.voidPromise()
Return a special ChannelPromise which can be reused for different operations.
|
ChannelPromise |
Channel.Unsafe.voidPromise()
Return a special ChannelPromise which can be reused and passed to the operations in
Channel.Unsafe . |
ChannelPromise |
AbstractChannel.voidPromise() |
ChannelPromise |
AbstractChannel.AbstractUnsafe.voidPromise() |
限定符和类型 | 方法和说明 |
---|---|
ChannelFlushPromiseNotifier |
ChannelFlushPromiseNotifier.add(ChannelPromise promise,
int pendingDataSize)
|
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 |
CombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelHandlerContext.bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Called once a bind operation is made.
|
void |
ChannelDuplexHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelHandlerContext.bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
ChannelFuture |
DefaultChannelPipeline.bind(java.net.SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
ChannelPipeline.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 |
ChannelHandlerContext.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 |
Channel.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. |
void |
Channel.Unsafe.bind(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 |
CombinedChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelHandlerContext.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a close operation is made.
|
void |
ChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelHandlerContext.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
ChannelFuture |
DefaultChannelPipeline.close(ChannelPromise promise) |
ChannelFuture |
ChannelPipeline.close(ChannelPromise promise)
Request to close the
Channel bound to this ChannelPipeline and notify the ChannelFuture
once the operation completes, either because the operation was successful or because of
an error. |
ChannelFuture |
ChannelHandlerContext.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 |
Channel.close(ChannelPromise promise)
Request to close this
Channel and notify the ChannelFuture once the operation completes,
either because the operation was successful or because of
an error. |
void |
Channel.Unsafe.close(ChannelPromise promise)
Close the
Channel of the ChannelPromise and notify the ChannelPromise once the
operation was complete. |
ChannelFuture |
AbstractChannel.close(ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.close(ChannelPromise promise) |
void |
CombinedChannelDuplexHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelHandlerContext.connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Called once a connect operation is made.
|
void |
ChannelDuplexHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelHandlerContext.connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
ChannelFuture |
DefaultChannelPipeline.connect(java.net.SocketAddress remoteAddress,
ChannelPromise promise) |
ChannelFuture |
ChannelPipeline.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 |
ChannelHandlerContext.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 |
Channel.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 |
AbstractChannel.connect(java.net.SocketAddress remoteAddress,
ChannelPromise promise) |
ChannelFuture |
DefaultChannelPipeline.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
ChannelPipeline.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 |
ChannelHandlerContext.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 |
Channel.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 |
Channel.Unsafe.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
|
ChannelFuture |
AbstractChannel.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
CombinedChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelHandlerContext.deregister(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a deregister operation is made from the current registered
EventLoop . |
void |
ChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelHandlerContext.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
ChannelFuture |
DefaultChannelPipeline.deregister(ChannelPromise promise) |
ChannelFuture |
ChannelPipeline.deregister(ChannelPromise promise)
Request to deregister the
Channel bound this ChannelPipeline 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 |
ChannelHandlerContext.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 |
Channel.deregister(ChannelPromise promise)
Request to deregister this
Channel from the previous assigned EventExecutor and notify the
ChannelFuture once the operation completes, either because the operation was successful or because of
an error. |
void |
Channel.Unsafe.deregister(ChannelPromise promise)
Deregister the
Channel of the ChannelPromise from EventLoop and notify the
ChannelPromise once the operation was complete. |
ChannelFuture |
AbstractChannel.deregister(ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.deregister(ChannelPromise promise) |
void |
CombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelHandlerContext.disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a disconnect operation is made.
|
void |
ChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelHandlerContext.disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
ChannelFuture |
DefaultChannelPipeline.disconnect(ChannelPromise promise) |
ChannelFuture |
ChannelPipeline.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 |
ChannelHandlerContext.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 |
Channel.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. |
void |
Channel.Unsafe.disconnect(ChannelPromise promise)
Disconnect the
Channel of the ChannelFuture and notify the ChannelPromise once the
operation was complete. |
ChannelFuture |
AbstractChannel.disconnect(ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.disconnect(ChannelPromise promise) |
protected boolean |
AbstractChannel.AbstractUnsafe.ensureOpen(ChannelPromise promise) |
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(Channel channel,
ChannelPromise promise) |
ChannelFuture |
ThreadPerChannelEventLoop.register(Channel channel,
ChannelPromise promise) |
ChannelFuture |
SingleThreadEventLoop.register(Channel channel,
ChannelPromise promise) |
ChannelFuture |
MultithreadEventLoopGroup.register(Channel channel,
ChannelPromise promise) |
ChannelFuture |
EventLoopGroup.register(Channel channel,
ChannelPromise promise)
|
void |
Channel.Unsafe.register(EventLoop eventLoop,
ChannelPromise promise)
Register the
Channel of the ChannelPromise with the EventLoop and notify
the ChannelFuture once the registration was complete. |
void |
AbstractChannel.AbstractUnsafe.register(EventLoop eventLoop,
ChannelPromise promise) |
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. |
void |
AbstractChannel.AbstractUnsafe.shutdownOutput(ChannelPromise promise)
Shutdown the output portion of the corresponding
Channel . |
void |
CombinedChannelDuplexHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Calls
ChannelHandlerContext.write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Called once a write operation is made.
|
void |
ChannelDuplexHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Calls
ChannelHandlerContext.write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
ChannelFuture |
DefaultChannelPipeline.write(java.lang.Object msg,
ChannelPromise promise) |
ChannelFuture |
ChannelPipeline.write(java.lang.Object msg,
ChannelPromise promise)
Request to write a message via this
ChannelPipeline . |
ChannelFuture |
ChannelHandlerContext.write(java.lang.Object msg,
ChannelPromise promise)
Request to write a message via this
ChannelHandlerContext through the ChannelPipeline . |
ChannelFuture |
Channel.write(java.lang.Object msg,
ChannelPromise promise)
Request to write a message via this
Channel through the ChannelPipeline . |
void |
Channel.Unsafe.write(java.lang.Object msg,
ChannelPromise promise)
Schedules a write operation.
|
ChannelFuture |
AbstractChannel.write(java.lang.Object msg,
ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.write(java.lang.Object msg,
ChannelPromise promise) |
ChannelFuture |
DefaultChannelPipeline.writeAndFlush(java.lang.Object msg,
ChannelPromise promise) |
ChannelFuture |
ChannelPipeline.writeAndFlush(java.lang.Object msg,
ChannelPromise promise)
Shortcut for call
ChannelPipeline.write(Object, ChannelPromise) and ChannelPipeline.flush() . |
ChannelFuture |
ChannelHandlerContext.writeAndFlush(java.lang.Object msg,
ChannelPromise promise)
Shortcut for call
ChannelHandlerContext.write(Object, ChannelPromise) and ChannelHandlerContext.flush() . |
ChannelFuture |
Channel.writeAndFlush(java.lang.Object msg,
ChannelPromise promise)
Shortcut for call
Channel.write(Object, ChannelPromise) and Channel.flush() . |
ChannelFuture |
AbstractChannel.writeAndFlush(java.lang.Object msg,
ChannelPromise promise) |
构造器和说明 |
---|
ChannelPromiseAggregator(ChannelPromise aggregatePromise)
已过时。
|
ChannelPromiseNotifier(boolean logNotifyFailure,
ChannelPromise... promises)
Create a new instance
|
ChannelPromiseNotifier(ChannelPromise... promises)
Create a new instance
|
限定符和类型 | 方法和说明 |
---|---|
ChannelFuture |
EmbeddedChannel.close(ChannelPromise promise) |
ChannelFuture |
EmbeddedChannel.disconnect(ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
ChannelFuture |
EpollDatagramChannel.block(java.net.InetAddress multicastAddress,
java.net.InetAddress sourceToBlock,
ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.block(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress sourceToBlock,
ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.joinGroup(java.net.InetAddress multicastAddress,
ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.joinGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source,
ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface,
ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress,
ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source,
ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface,
ChannelPromise promise) |
ChannelFuture |
AbstractEpollStreamChannel.shutdownOutput(ChannelPromise promise) |
ChannelFuture |
AbstractEpollStreamChannel.spliceTo(AbstractEpollStreamChannel ch,
int len,
ChannelPromise promise)
Splice from this
AbstractEpollStreamChannel to another AbstractEpollStreamChannel . |
ChannelFuture |
AbstractEpollStreamChannel.spliceTo(FileDescriptor ch,
int offset,
int len,
ChannelPromise promise)
Splice from this
AbstractEpollStreamChannel to another FileDescriptor . |
构造器和说明 |
---|
AbstractEpollStreamChannel.SpliceInTask(int len,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
void |
AbstractNioChannel.AbstractNioUnsafe.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
ChannelFuture |
SctpServerChannel.bindAddress(java.net.InetAddress localAddress,
ChannelPromise promise)
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.unbindAddress(java.net.InetAddress localAddress,
ChannelPromise promise)
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 |
NioSctpServerChannel.bindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
NioSctpChannel.bindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
NioSctpServerChannel.unbindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
NioSctpChannel.unbindAddress(java.net.InetAddress localAddress,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
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) |
限定符和类型 | 方法和说明 |
---|---|
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.shutdownOutput(ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
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.shutdownOutput(ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
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.shutdownOutput(ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
void |
SpdyFrameLogger.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
SpdyClientStreamIdHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
void |
MessageToMessageEncoder.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
MessageToMessageCodec.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) |
限定符和类型 | 方法和说明 |
---|---|
void |
JZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JdkZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
abstract ChannelFuture |
ZlibEncoder.close(ChannelPromise promise)
Close this
ZlibEncoder and so finish the encoding. |
ChannelFuture |
JZlibEncoder.close(ChannelPromise promise) |
ChannelFuture |
JdkZlibEncoder.close(ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
void |
HttpServerKeepAliveHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
void |
CorsHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
ChannelFuture |
WebSocketServerHandshaker00.close(Channel channel,
CloseWebSocketFrame frame,
ChannelPromise promise)
Echo back the closing frame
|
ChannelFuture |
WebSocketServerHandshaker.close(Channel channel,
CloseWebSocketFrame frame,
ChannelPromise promise)
Performs the closing handshake
|
ChannelFuture |
WebSocketClientHandshaker.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
|
限定符和类型 | 方法和说明 |
---|---|
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) |
void |
SpdySessionHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
SpdyFrameCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
void |
FlushConsolidationHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
FlushConsolidationHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
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) |
限定符和类型 | 方法和说明 |
---|---|
void |
SslHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SslHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
SslHandler.close(ChannelPromise promise)
已过时。
|
void |
SslHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SslHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
void |
ChunkedWriteHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
void |
WriteTimeoutHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
IdleStateHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long delay,
ChannelPromise promise)
已过时。
|
protected void |
GlobalChannelTrafficShapingHandler.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) |