AbstractKQueueStreamChannel.KQueueStreamUnsafe

java.lang.Object

io.netty.channel.AbstractChannel.AbstractUnsafe

io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe

io.netty.channel.kqueue.AbstractKQueueStreamChannel.KQueueStreamUnsafe

All Implemented Interfaces:: Channel.Unsafe

Direct Known Subclasses:: KQueueDomainSocketChannel.KQueueDomainUnsafe, KQueueSocketChannel.KQueueSocketChannelUnsafe

Enclosing class:: AbstractKQueueStreamChannel

class AbstractKQueueStreamChannel.KQueueStreamUnsafe extends AbstractKQueueChannel.AbstractKQueueUnsafe

Field Summary

Fields inherited from class io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe
maybeMoreDataToRead, readPending
Constructor Summary

Constructors

Constructor

Description

KQueueStreamUnsafe()
Method Summary

Modifier and Type

Method

Description

private void

handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, Throwable cause, boolean close, KQueueRecvByteAllocatorHandle allocHandle)

protected Executor

prepareToClose()

Prepares to close the Channel.

(package private) void

readReady(KQueueRecvByteAllocatorHandle allocHandle)

Methods inherited from class io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe
clearReadFilter0, connect, executeReadReadyRunnable, failConnectPromise, flush0, readEOF, readReady, readReadyBefore, readReadyFinally, recvBufAllocHandle, shutdownInput, writeReady

Methods inherited from class io.netty.channel.AbstractChannel.AbstractUnsafe
annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, handleWriteError, localAddress, outboundBuffer, register, remoteAddress, safeSetFailure, safeSetSuccess, shutdownOutput, voidPromise, write

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- KQueueStreamUnsafe
  
  KQueueStreamUnsafe()
Method Details
- prepareToClose
  
  protected Executor prepareToClose()
  
  Description copied from class: AbstractChannel.AbstractUnsafe
  
  Prepares to close the 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)
  
  Overrides:
  
  prepareToClose in class AbstractChannel.AbstractUnsafe
- readReady
  
  void readReady(KQueueRecvByteAllocatorHandle allocHandle)
  
  Specified by:
  
  readReady in class AbstractKQueueChannel.AbstractKQueueUnsafe
- handleReadException
  
  private void handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, Throwable cause, boolean close, KQueueRecvByteAllocatorHandle allocHandle)