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

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`private void`	`handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, java.lang.Throwable cause, boolean close, KQueueRecvByteAllocatorHandle allocHandle)`
`protected java.util.concurrent.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 Detail
  - KQueueStreamUnsafe
```
KQueueStreamUnsafe()
```
- Method Detail
  - prepareToClose
```
protected java.util.concurrent.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,
                                 java.lang.Throwable cause,
                                 boolean close,
                                 KQueueRecvByteAllocatorHandle allocHandle)
```