public class ChannelAsyncInputStream extends CloseableUtils.AbstractCloseable implements IoInputStream
Modifier and Type | Class and Description |
---|---|
static class |
ChannelAsyncInputStream.IoReadFutureImpl |
CloseableUtils.AbstractCloseable.State
closeFuture, lock, log, state
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
public ChannelAsyncInputStream(Channel channel)
public void write(Readable src) throws IOException
IOException
public IoReadFuture read(Buffer buf)
IoInputStream
read
in interface IoInputStream
protected void preClose()
CloseableUtils.AbstractCloseable
preClose
in class CloseableUtils.AbstractCloseable
protected CloseFuture doCloseGracefully()
doCloseGracefully
in class CloseableUtils.AbstractCloseable
Copyright © 2008–2016 The Apache Software Foundation. All rights reserved.