private final class KQueueSocketChannel.KQueueSocketChannelUnsafe extends AbstractKQueueStreamChannel.KQueueStreamUnsafe
maybeMoreDataToRead, readPending
Modifier | Constructor and Description |
---|---|
private |
KQueueSocketChannelUnsafe() |
Modifier and Type | Method and Description |
---|---|
(package private) boolean |
doFinishConnect() |
protected java.util.concurrent.Executor |
prepareToClose()
Prepares to close the
Channel . |
connect, readReady, writeReady
clearReadFilter0, executeReadReadyRunnable, readEOF, readReady, readReadyBefore, readReadyFinally, recvBufAllocHandle, shutdownInput
annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, flush0, localAddress, outboundBuffer, register, remoteAddress, safeSetFailure, safeSetSuccess, voidPromise, write
protected java.util.concurrent.Executor prepareToClose()
AbstractChannel.AbstractUnsafe
Channel
. If this method returns an Executor
, the
caller must call the Executor.execute(Runnable)
method with a task that calls
AbstractChannel.doClose()
on the returned Executor
. If this method returns null
,
AbstractChannel.doClose()
must be called from the caller thread. (i.e. EventLoop
)prepareToClose
in class AbstractKQueueStreamChannel.KQueueStreamUnsafe
boolean doFinishConnect() throws java.lang.Exception
doFinishConnect
in class AbstractKQueueStreamChannel.KQueueStreamUnsafe
java.lang.Exception