public class ChannelAsyncOutputStream extends AbstractCloseable implements IoOutputStream, ChannelHolder
AbstractCloseable.State
closeFuture, lock, state
log
CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT
Constructor and Description |
---|
ChannelAsyncOutputStream(Channel channel,
byte cmd) |
Modifier and Type | Method and Description |
---|---|
protected CloseFuture |
doCloseGracefully() |
protected void |
doWriteIfPossible(boolean resume) |
Channel |
getChannel() |
void |
onWindowExpanded() |
protected void |
preClose()
preClose is guaranteed to be called before doCloseGracefully or doCloseImmediately.
|
String |
toString() |
IoWriteFuture |
writePacket(Buffer buffer)
Encode and send the given buffer.
|
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
public ChannelAsyncOutputStream(Channel channel, byte cmd)
public Channel getChannel()
getChannel
in interface ChannelHolder
Channel
instancepublic void onWindowExpanded() throws IOException
IOException
public IoWriteFuture writePacket(Buffer buffer) throws IOException
PacketWriter
writePacket
in interface PacketWriter
buffer
- the buffer to encode and send. NOTE: the buffer must not be touched
until the returned write future is completed.IoWriteFuture
that can be used to check when the packet has actually been sentIOException
- if an error occurred when encoding sending the packetprotected void preClose()
AbstractCloseable
preClose
in class AbstractCloseable
protected CloseFuture doCloseGracefully()
doCloseGracefully
in class AbstractCloseable
protected void doWriteIfPossible(boolean resume)
Copyright © 2008–2022 The Apache Software Foundation. All rights reserved.