final class KQueueDatagramChannel.KQueueDatagramChannelUnsafe extends AbstractKQueueChannel.AbstractKQueueUnsafe
maybeMoreDataToRead, readPending
Constructor and Description |
---|
KQueueDatagramChannelUnsafe() |
Modifier and Type | Method and Description |
---|---|
void |
connect(java.net.SocketAddress remote,
java.net.SocketAddress local,
ChannelPromise channelPromise)
|
(package private) void |
readReady(KQueueRecvByteAllocatorHandle allocHandle) |
clearReadFilter0, executeReadReadyRunnable, readEOF, readReady, readReadyBefore, readReadyFinally, recvBufAllocHandle, shutdownInput, writeReady
annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, flush0, localAddress, outboundBuffer, prepareToClose, register, remoteAddress, safeSetFailure, safeSetSuccess, voidPromise, write
public void connect(java.net.SocketAddress remote, java.net.SocketAddress local, ChannelPromise channelPromise)
Channel.Unsafe
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 readReady(KQueueRecvByteAllocatorHandle allocHandle)
readReady
in class AbstractKQueueChannel.AbstractKQueueUnsafe