protected static class ChannelAsyncOutputStream.WriteState extends Object
Modifier and Type | Field and Description |
---|---|
protected IoWriteFuture |
lastWrite
The future describing the last executed *buffer* write
ChannelAsyncOutputStream.writeBuffer(Buffer) . |
protected AbstractCloseable.State |
openState
A copy of this stream's state as set by the superclass.
|
protected IoWriteFutureImpl |
pendingWrite
The future describing the current packet write; if
null , there is nothing to write or
ChannelAsyncOutputStream.writePacket(IoWriteFutureImpl, boolean) is running. |
protected int |
toSend
Number of bytes still to send.
|
protected int |
totalLength
Number of bytes to send in total.
|
protected boolean |
windowExpanded
Set to true when there was a remote window expansion while
ChannelAsyncOutputStream.writePacket(IoWriteFutureImpl, boolean) was in progress. |
protected boolean |
writeInProgress
Flag to throw an exception if non-sequential
ChannelAsyncOutputStream.writeBuffer(Buffer) calls
should occur. |
Modifier | Constructor and Description |
---|---|
protected |
WriteState() |
protected IoWriteFuture lastWrite
ChannelAsyncOutputStream.writeBuffer(Buffer)
.
Used for graceful closing.protected IoWriteFutureImpl pendingWrite
null
, there is nothing to write or
ChannelAsyncOutputStream.writePacket(IoWriteFutureImpl, boolean)
is running.protected boolean writeInProgress
ChannelAsyncOutputStream.writeBuffer(Buffer)
calls
should occur.protected boolean windowExpanded
ChannelAsyncOutputStream.writePacket(IoWriteFutureImpl, boolean)
was in progress. If set,
ChannelAsyncOutputStream.doWriteIfPossible(boolean)
will run a
ChannelAsyncOutputStream.writePacket(IoWriteFutureImpl, boolean)
again.protected AbstractCloseable.State openState
protected int totalLength
protected int toSend
Copyright © 2008–2024 The Apache Software Foundation. All rights reserved.