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, IoHandle, KQueueIoHandle, AutoCloseable

Direct Known Subclasses:: KQueueDomainSocketChannel.KQueueDomainUnsafe

Enclosing class:: AbstractKQueueStreamChannel

class AbstractKQueueStreamChannel.KQueueStreamUnsafe extends AbstractKQueueChannel.AbstractKQueueUnsafe

Field Summary

Fields inherited from class io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe
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)

(package private) void

readReady(KQueueRecvByteAllocatorHandle allocHandle)

Methods inherited from class io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe
channel, clearReadFilter0, close, connect, failConnectPromise, flush0, handle, ident, recvBufAllocHandle, shouldStopReading, shutdownInput

Methods inherited from class io.netty.channel.AbstractChannel.AbstractUnsafe
annotateConnectException, beginRead, bind, close, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, handleWriteError, localAddress, outboundBuffer, prepareToClose, 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

Methods inherited from interface io.netty.channel.IoHandle
registered, unregistered

Constructor Details
- KQueueStreamUnsafe
  
  KQueueStreamUnsafe()
Method Details
- 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)