Package | Description |
---|---|
io.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
io.netty.channel.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.nio |
NIO-based channel
API implementation - recommended for a large 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).
|
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelProgressivePromise
Special
ChannelPromise which will be notified once the associated bytes is transferring. |
Modifier and Type | Class and Description |
---|---|
class |
DefaultChannelProgressivePromise
The default
ChannelProgressivePromise implementation. |
class |
DefaultChannelPromise
The default
ChannelPromise implementation. |
class |
DelegatingChannelPromiseNotifier |
class |
VoidChannelPromise |
Modifier and Type | Method and Description |
---|---|
ChannelPromise |
DelegatingChannelPromiseNotifier.addListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener) |
ChannelPromise |
ChannelPromise.addListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener) |
ChannelPromise |
DefaultChannelPromise.addListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener) |
ChannelPromise |
DelegatingChannelPromiseNotifier.addListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>... listeners) |
ChannelPromise |
ChannelPromise.addListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>... listeners) |
ChannelPromise |
DefaultChannelPromise.addListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>... listeners) |
ChannelPromise |
DelegatingChannelPromiseNotifier.await() |
ChannelPromise |
ChannelPromise.await() |
ChannelPromise |
DefaultChannelPromise.await() |
ChannelPromise |
DelegatingChannelPromiseNotifier.awaitUninterruptibly() |
ChannelPromise |
ChannelPromise.awaitUninterruptibly() |
ChannelPromise |
DefaultChannelPromise.awaitUninterruptibly() |
ChannelPromise |
DefaultChannelPipeline.newPromise() |
ChannelPromise |
AbstractChannel.newPromise() |
ChannelPromise |
ChannelOutboundInvoker.newPromise()
Return a new
ChannelPromise . |
ChannelPromise |
DefaultChannelPromise.promise() |
ChannelPromise |
PendingWriteQueue.remove()
Removes a pending write operation and release it's message via
ReferenceCountUtil.safeRelease(Object) . |
ChannelPromise |
DelegatingChannelPromiseNotifier.removeListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener) |
ChannelPromise |
ChannelPromise.removeListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener) |
ChannelPromise |
DefaultChannelPromise.removeListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener) |
ChannelPromise |
DelegatingChannelPromiseNotifier.removeListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>... listeners) |
ChannelPromise |
ChannelPromise.removeListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>... listeners) |
ChannelPromise |
DefaultChannelPromise.removeListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>... listeners) |
ChannelPromise |
DelegatingChannelPromiseNotifier.setFailure(Throwable cause) |
ChannelPromise |
ChannelPromise.setFailure(Throwable cause) |
ChannelPromise |
DefaultChannelPromise.setFailure(Throwable cause) |
ChannelPromise |
DelegatingChannelPromiseNotifier.setSuccess() |
ChannelPromise |
ChannelPromise.setSuccess() |
ChannelPromise |
DefaultChannelPromise.setSuccess() |
ChannelPromise |
DelegatingChannelPromiseNotifier.setSuccess(Void result) |
ChannelPromise |
ChannelPromise.setSuccess(Void result) |
ChannelPromise |
DefaultChannelPromise.setSuccess(Void result) |
ChannelPromise |
DelegatingChannelPromiseNotifier.sync() |
ChannelPromise |
ChannelPromise.sync() |
ChannelPromise |
DefaultChannelPromise.sync() |
ChannelPromise |
DelegatingChannelPromiseNotifier.syncUninterruptibly() |
ChannelPromise |
ChannelPromise.syncUninterruptibly() |
ChannelPromise |
DefaultChannelPromise.syncUninterruptibly() |
ChannelPromise |
DelegatingChannelPromiseNotifier.unvoid() |
ChannelPromise |
VoidChannelPromise.unvoid() |
ChannelPromise |
ChannelPromise.unvoid()
|
ChannelPromise |
DefaultChannelPromise.unvoid() |
ChannelPromise |
Channel.Unsafe.voidPromise()
Return a special ChannelPromise which can be reused and passed to the operations in
Channel.Unsafe . |
ChannelPromise |
DefaultChannelPipeline.voidPromise() |
ChannelPromise |
AbstractChannel.voidPromise() |
ChannelPromise |
AbstractChannel.AbstractUnsafe.voidPromise() |
ChannelPromise |
ChannelOutboundInvoker.voidPromise()
Return a special ChannelPromise which can be reused for different operations.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractCoalescingBufferQueue.add(io.netty.buffer.ByteBuf buf,
ChannelPromise promise)
Add a buffer to the end of the queue and associate a promise with it that should be completed when
all the buffer's bytes have been consumed from the queue and written.
|
ChannelFlushPromiseNotifier |
ChannelFlushPromiseNotifier.add(ChannelPromise promise,
int pendingDataSize)
Deprecated.
|
ChannelFlushPromiseNotifier |
ChannelFlushPromiseNotifier.add(ChannelPromise promise,
long pendingDataSize)
Add a
ChannelPromise to this ChannelFlushPromiseNotifier which will be notified after the given
pendingDataSize was reached. |
void |
PendingWriteQueue.add(Object msg,
ChannelPromise promise)
Add the given
msg and ChannelPromise . |
void |
AbstractCoalescingBufferQueue.addFirst(io.netty.buffer.ByteBuf buf,
ChannelPromise promise)
Add a buffer to the front of the queue and associate a promise with it that should be completed when
all the buffer's bytes have been consumed from the queue and written.
|
void |
ChannelOutboundBuffer.addMessage(Object msg,
int size,
ChannelPromise promise)
Add given message to this
ChannelOutboundBuffer . |
void |
CombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Called once a bind operation is made.
|
void |
Channel.Unsafe.bind(SocketAddress localAddress,
ChannelPromise promise)
|
ChannelFuture |
DefaultChannelPipeline.bind(SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.bind(SocketAddress localAddress,
ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.bind(SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.bind(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 |
CombinedChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a close operation is made.
|
void |
Channel.Unsafe.close(ChannelPromise promise)
Close the
Channel of the ChannelPromise and notify the ChannelPromise once the
operation was complete. |
ChannelFuture |
DefaultChannelPipeline.close(ChannelPromise promise) |
ChannelFuture |
AbstractChannel.close(ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.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. |
void |
CombinedChannelDuplexHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise)
Called once a connect operation is made.
|
ChannelFuture |
DefaultChannelPipeline.connect(SocketAddress remoteAddress,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.connect(SocketAddress remoteAddress,
ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.connect(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. |
void |
Channel.Unsafe.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise)
|
ChannelFuture |
DefaultChannelPipeline.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.connect(SocketAddress remoteAddress,
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 |
CombinedChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.deregister(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.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 |
Channel.Unsafe.deregister(ChannelPromise promise)
Deregister the
Channel of the ChannelPromise from EventLoop and notify the
ChannelPromise once the operation was complete. |
ChannelFuture |
DefaultChannelPipeline.deregister(ChannelPromise promise) |
ChannelFuture |
AbstractChannel.deregister(ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.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. |
void |
CombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a disconnect operation is made.
|
void |
Channel.Unsafe.disconnect(ChannelPromise promise)
Disconnect the
Channel of the ChannelFuture and notify the ChannelPromise once the
operation was complete. |
ChannelFuture |
DefaultChannelPipeline.disconnect(ChannelPromise promise) |
ChannelFuture |
AbstractChannel.disconnect(ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.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. |
protected boolean |
AbstractChannel.AbstractUnsafe.ensureOpen(ChannelPromise promise) |
ChannelFuture |
EventLoopGroup.register(Channel channel,
ChannelPromise promise)
Deprecated.
Use
EventLoopGroup.register(ChannelPromise) instead. |
ChannelFuture |
SingleThreadEventLoop.register(Channel channel,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
ThreadPerChannelEventLoop.register(Channel channel,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
MultithreadEventLoopGroup.register(Channel channel,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(Channel channel,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
EventLoopGroup.register(ChannelPromise promise)
|
ChannelFuture |
SingleThreadEventLoop.register(ChannelPromise promise) |
ChannelFuture |
ThreadPerChannelEventLoop.register(ChannelPromise promise)
Deprecated.
|
ChannelFuture |
MultithreadEventLoopGroup.register(ChannelPromise promise) |
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(ChannelPromise promise)
Deprecated.
|
void |
Channel.Unsafe.register(EventLoop eventLoop,
ChannelPromise promise)
Register the
Channel of the ChannelPromise and notify
the ChannelFuture once the registration was complete. |
void |
AbstractChannel.AbstractUnsafe.register(EventLoop eventLoop,
ChannelPromise promise) |
io.netty.buffer.ByteBuf |
AbstractCoalescingBufferQueue.remove(io.netty.buffer.ByteBufAllocator alloc,
int bytes,
ChannelPromise aggregatePromise)
Remove a
ByteBuf from the queue with the specified number of bytes. |
io.netty.buffer.ByteBuf |
CoalescingBufferQueue.remove(int bytes,
ChannelPromise aggregatePromise)
Remove a
ByteBuf from the queue with the specified number of bytes. |
io.netty.buffer.ByteBuf |
AbstractCoalescingBufferQueue.removeFirst(ChannelPromise aggregatePromise)
Remove the first
ByteBuf from the queue. |
protected void |
AbstractChannel.AbstractUnsafe.safeSetFailure(ChannelPromise promise,
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,
Object msg,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Called once a write operation is made.
|
void |
Channel.Unsafe.write(Object msg,
ChannelPromise promise)
Schedules a write operation.
|
ChannelFuture |
DefaultChannelPipeline.write(Object msg,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.write(Object msg,
ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.write(Object msg,
ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.write(Object msg,
ChannelPromise promise)
Request to write a message via this
ChannelHandlerContext through the ChannelPipeline . |
ChannelFuture |
DefaultChannelPipeline.writeAndFlush(Object msg,
ChannelPromise promise) |
ChannelFuture |
AbstractChannel.writeAndFlush(Object msg,
ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.writeAndFlush(Object msg,
ChannelPromise promise)
Shortcut for call
ChannelOutboundInvoker.write(Object, ChannelPromise) and ChannelOutboundInvoker.flush() . |
Constructor and Description |
---|
ChannelPromiseAggregator(ChannelPromise aggregatePromise)
Deprecated.
|
ChannelPromiseNotifier(boolean logNotifyFailure,
ChannelPromise... promises)
Create a new instance
|
ChannelPromiseNotifier(ChannelPromise... promises)
Create a new instance
|
DelegatingChannelPromiseNotifier(ChannelPromise delegate) |
DelegatingChannelPromiseNotifier(ChannelPromise delegate,
boolean logNotifyFailure) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
EmbeddedChannel.close(ChannelPromise promise) |
ChannelFuture |
EmbeddedChannel.disconnect(ChannelPromise promise) |
ChannelFuture |
EmbeddedChannel.writeOneInbound(Object msg,
ChannelPromise promise)
Writes one message to the inbound of this
Channel and does not flush it. |
ChannelFuture |
EmbeddedChannel.writeOneOutbound(Object msg,
ChannelPromise promise)
Writes one message to the outbound of this
Channel and does not flush it. |
Modifier and Type | Method and Description |
---|---|
void |
AbstractNioChannel.AbstractNioUnsafe.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
DatagramChannel.block(InetAddress multicastAddress,
InetAddress sourceToBlock,
ChannelPromise future)
Block the given sourceToBlock address for the given multicastAddress and notifies the
ChannelFuture once
the operation completes. |
ChannelFuture |
DatagramChannel.block(InetAddress multicastAddress,
NetworkInterface networkInterface,
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(InetAddress multicastAddress,
ChannelPromise future)
Joins a multicast group and notifies the
ChannelFuture once the operation completes. |
ChannelFuture |
DatagramChannel.joinGroup(InetAddress multicastAddress,
NetworkInterface networkInterface,
InetAddress source,
ChannelPromise future)
Joins the specified multicast group at the specified interface and notifies the
ChannelFuture
once the operation completes. |
ChannelFuture |
DatagramChannel.joinGroup(InetSocketAddress multicastAddress,
NetworkInterface networkInterface,
ChannelPromise future)
Joins the specified multicast group at the specified interface and notifies the
ChannelFuture
once the operation completes. |
ChannelFuture |
DatagramChannel.leaveGroup(InetAddress multicastAddress,
ChannelPromise future)
Leaves a multicast group and notifies the
ChannelFuture once the operation completes. |
ChannelFuture |
DatagramChannel.leaveGroup(InetAddress multicastAddress,
NetworkInterface networkInterface,
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(InetSocketAddress multicastAddress,
NetworkInterface networkInterface,
ChannelPromise future)
Leaves a multicast group on a specified local interface and notifies the
ChannelFuture once the
operation completes. |
ChannelFuture |
DuplexChannel.shutdown(ChannelPromise promise)
Will shutdown the input and output sides of this channel.
|
ChannelFuture |
DuplexChannel.shutdownInput(ChannelPromise promise)
Will shutdown the input and notify
ChannelPromise . |
ChannelFuture |
DuplexChannel.shutdownOutput(ChannelPromise promise)
Will shutdown the output and notify
ChannelPromise . |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
NioDatagramChannel.block(InetAddress multicastAddress,
InetAddress sourceToBlock,
ChannelPromise promise)
Block the given sourceToBlock address for the given multicastAddress
|
ChannelFuture |
NioDatagramChannel.block(InetAddress multicastAddress,
NetworkInterface networkInterface,
InetAddress sourceToBlock,
ChannelPromise promise)
Block the given sourceToBlock address for the given multicastAddress on the given networkInterface
|
ChannelFuture |
NioDatagramChannel.joinGroup(InetAddress multicastAddress,
ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.joinGroup(InetAddress multicastAddress,
NetworkInterface networkInterface,
InetAddress source,
ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.joinGroup(InetSocketAddress multicastAddress,
NetworkInterface networkInterface,
ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.leaveGroup(InetAddress multicastAddress,
ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.leaveGroup(InetAddress multicastAddress,
NetworkInterface networkInterface,
InetAddress source,
ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.leaveGroup(InetSocketAddress multicastAddress,
NetworkInterface networkInterface,
ChannelPromise promise) |
ChannelFuture |
NioSocketChannel.shutdown(ChannelPromise promise) |
ChannelFuture |
NioSocketChannel.shutdownInput(ChannelPromise promise) |
ChannelFuture |
NioSocketChannel.shutdownOutput(ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
OioDatagramChannel.block(InetAddress multicastAddress,
InetAddress sourceToBlock,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
OioDatagramChannel.block(InetAddress multicastAddress,
NetworkInterface networkInterface,
InetAddress sourceToBlock,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
OioDatagramChannel.joinGroup(InetAddress multicastAddress,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
OioDatagramChannel.joinGroup(InetAddress multicastAddress,
NetworkInterface networkInterface,
InetAddress source,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
OioDatagramChannel.joinGroup(InetSocketAddress multicastAddress,
NetworkInterface networkInterface,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
OioDatagramChannel.leaveGroup(InetAddress multicastAddress,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
OioDatagramChannel.leaveGroup(InetAddress multicastAddress,
NetworkInterface networkInterface,
InetAddress source,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
OioDatagramChannel.leaveGroup(InetSocketAddress multicastAddress,
NetworkInterface networkInterface,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
OioSocketChannel.shutdown(ChannelPromise promise)
Deprecated.
|
ChannelFuture |
OioSocketChannel.shutdownInput(ChannelPromise promise)
Deprecated.
|
ChannelFuture |
OioSocketChannel.shutdownOutput(ChannelPromise promise)
Deprecated.
|
Copyright © 2008–2019 The Netty Project. All rights reserved.