public class ChannelAsyncInputStream extends AbstractCloseable implements IoInputStream
Modifier and Type | Class and Description |
---|---|
static class |
ChannelAsyncInputStream.IoReadFutureImpl |
AbstractCloseable.State
closeFuture, lock, state
log
Constructor and Description |
---|
ChannelAsyncInputStream(Channel channel) |
Modifier and Type | Method and Description |
---|---|
protected CloseFuture |
doCloseGracefully() |
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.
|
String |
toString() |
void |
write(Readable src) |
builder, close, doCloseImmediately, isClosed, isClosing
close, isOpen
public ChannelAsyncInputStream(Channel channel)
public void write(Readable src) throws IOException
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
Copyright © 2008–2016 The Apache Software Foundation. All rights reserved.