public static interface Channel.Unsafe
| Modifier and Type | Method and Description |
|---|---|
void |
beginRead()
Schedules a read operation that fills the inbound buffer of the first
ChannelInboundHandler in the
ChannelPipeline. |
void |
bind(java.net.SocketAddress localAddress,
ChannelPromise promise)
|
void |
close(ChannelPromise promise)
Close the
Channel of the ChannelPromise and notify the ChannelPromise once the
operation was complete. |
void |
closeForcibly()
Closes the
Channel immediately without firing any events. |
void |
connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
|
void |
deregister(ChannelPromise promise)
Deregister the
Channel of the ChannelPromise from EventLoop and notify the
ChannelPromise once the operation was complete. |
void |
disconnect(ChannelPromise promise)
Disconnect the
Channel of the ChannelFuture and notify the ChannelPromise once the
operation was complete. |
void |
flush()
Flush out all write operations scheduled via
write(Object, ChannelPromise). |
java.net.SocketAddress |
localAddress()
Return the
SocketAddress to which is bound local or
null if none. |
ChannelOutboundBuffer |
outboundBuffer()
Returns the
ChannelOutboundBuffer of the Channel where the pending write requests are stored. |
void |
register(EventLoop eventLoop,
ChannelPromise promise)
Register the
Channel of the ChannelPromise with the EventLoop and notify
the ChannelFuture once the registration was complete. |
java.net.SocketAddress |
remoteAddress()
Return the
SocketAddress to which is bound remote or
null if none is bound yet. |
ChannelPromise |
voidPromise()
Return a special ChannelPromise which can be reused and passed to the operations in
Channel.Unsafe. |
void |
write(java.lang.Object msg,
ChannelPromise promise)
Schedules a write operation.
|
java.net.SocketAddress localAddress()
SocketAddress to which is bound local or
null if none.java.net.SocketAddress remoteAddress()
SocketAddress to which is bound remote or
null if none is bound yet.void register(EventLoop eventLoop, ChannelPromise promise)
Channel of the ChannelPromise with the EventLoop and notify
the ChannelFuture once the registration was complete.void bind(java.net.SocketAddress localAddress,
ChannelPromise promise)
void connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Channel of the given ChannelFuture with the given remote SocketAddress.
If a specific local SocketAddress should be used it need to be given as argument. Otherwise just
pass null to it.
The ChannelPromise will get notified once the connect operation was complete.void disconnect(ChannelPromise promise)
Channel of the ChannelFuture and notify the ChannelPromise once the
operation was complete.void close(ChannelPromise promise)
Channel of the ChannelPromise and notify the ChannelPromise once the
operation was complete.void closeForcibly()
Channel immediately without firing any events. Probably only useful
when registration attempt failed.void deregister(ChannelPromise promise)
Channel of the ChannelPromise from EventLoop and notify the
ChannelPromise once the operation was complete.void beginRead()
ChannelInboundHandler in the
ChannelPipeline. If there's already a pending read operation, this method does nothing.void write(java.lang.Object msg,
ChannelPromise promise)
void flush()
write(Object, ChannelPromise).ChannelPromise voidPromise()
Channel.Unsafe.
It will never be notified of a success or error and so is only a placeholder for operations
that take a ChannelPromise as argument but for which you not want to get notified.ChannelOutboundBuffer outboundBuffer()
ChannelOutboundBuffer of the Channel where the pending write requests are stored.Copyright © 2008–2018 The Netty Project. All rights reserved.