public class ChannelAsyncInputStream extends AbstractCloseable implements IoInputStream, ChannelHolder
Modifier and Type | Class and Description |
---|---|
static class |
ChannelAsyncInputStream.IoReadFutureImpl |
AbstractCloseable.State
Modifier and Type | Field and Description |
---|---|
private Buffer |
buffer |
private Channel |
channelInstance |
private ChannelAsyncInputStream.IoReadFutureImpl |
pending |
private java.lang.Object |
readFutureId |
closeFuture, lock, state
log
CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT
Constructor and Description |
---|
ChannelAsyncInputStream(Channel channel) |
Modifier and Type | Method and Description |
---|---|
protected CloseFuture |
doCloseGracefully() |
private void |
doRead(boolean resume) |
Channel |
getChannel() |
protected void |
preClose()
preClose is guaranteed to be called before doCloseGracefully or doCloseImmediately.
|
IoReadFuture |
read(Buffer buf)
NOTE: the buffer must not be touched until the returned read future is completed.
|
java.lang.String |
toString() |
void |
write(Readable src) |
addCloseFutureListener, builder, close, doCloseImmediately, isClosed, isClosing, removeCloseFutureListener
getSimplifiedLogger
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
private final Channel channelInstance
private final Buffer buffer
private final java.lang.Object readFutureId
private ChannelAsyncInputStream.IoReadFutureImpl pending
public ChannelAsyncInputStream(Channel channel)
public Channel getChannel()
getChannel
in interface ChannelHolder
Channel
instancepublic void write(Readable src) throws java.io.IOException
java.io.IOException
public IoReadFuture read(Buffer buf)
IoInputStream
read
in interface IoInputStream
buf
- the Buffer
to useIoReadFuture
for the operationprotected void preClose()
AbstractCloseable
preClose
in class AbstractCloseable
protected CloseFuture doCloseGracefully()
doCloseGracefully
in class AbstractCloseable
private void doRead(boolean resume)
public java.lang.String toString()
toString
in class java.lang.Object