| Modifier and Type | Class and Description |
|---|---|
| private static class | |
| public static class | |
| private static class |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| public GrizzlyFuture | flush(final CompletionHandler<Integer> completionHandler)
Overrides org. Implements org. Cause the overflow handler to be called even if buffer is not full. |
| DefaultStreamWriter | back to summary |
|---|---|
| public DefaultStreamWriter(Connection<L> connection) | |
| flush | back to summary |
|---|---|
| public GrizzlyFuture Overrides org. Implements org. Doc from org. Cause the overflow handler to be called even if buffer is not full.
| |
| Modifier and Type | Field and Description |
|---|---|
| private final CompletionHandler | |
| private final FutureImpl | |
| private final DefaultStreamWriter. |
| Access | Constructor and Description |
|---|---|
| public | CompletionHandlerAdapter(DefaultStreamWriter.
|
| Modifier and Type | Method and Description |
|---|---|
| public void | cancelled()
Implements org. The operation was cancelled. |
| public void | completed(WriteResult<K, L> result)
Implements org. The operation was completed. |
| public void | failed(Throwable throwable)
Implements org. The operation was failed. |
| public void | updated(WriteResult<K, L> result)
Implements org. The callback method may be called, when there is some progress in operation execution, but it is still not completed |
| completionHandler | back to summary |
|---|---|
| private final CompletionHandler<Integer> completionHandler | |
| future | back to summary |
|---|---|
| private final FutureImpl<Integer> future | |
| output | back to summary |
|---|---|
| private final DefaultStreamWriter. | |
| CompletionHandlerAdapter | back to summary |
|---|---|
| public CompletionHandlerAdapter(DefaultStreamWriter. | |
| cancelled | back to summary |
|---|---|
| public void cancelled() Implements org. Doc from org. The operation was cancelled.
| |
| completed | back to summary |
|---|---|
| public void completed(WriteResult<K, L> result) Implements org. Doc from org. The operation was completed.
| |
| failed | back to summary |
|---|---|
| public void failed(Throwable throwable) Implements org. Doc from org. The operation was failed.
| |
| updated | back to summary |
|---|---|
| public void updated(WriteResult<K, L> result) Implements org. Doc from org. The callback method may be called, when there is some progress in operation execution, but it is still not completed
| |
| Modifier and Type | Field and Description |
|---|---|
| private final Connection | |
| private int |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| protected GrizzlyFuture | flush0(Buffer buffer, final CompletionHandler<Integer> completionHandler)
Implements abstract org.
|
| protected Buffer | |
| protected void | |
| protected Buffer | reallocateBuffer(Buffer oldBuffer, int size)
Implements abstract org.
|
| connection | back to summary |
|---|---|
| private final Connection<L> connection | |
| sentBytesCounter | back to summary |
|---|---|
| private int sentBytesCounter | |
| Output | back to summary |
|---|---|
| public Output(Connection<L> connection) | |
| flush0 | back to summary |
|---|---|
| protected GrizzlyFuture Implements abstract org.
| |
| newBuffer | back to summary |
|---|---|
| protected Buffer newBuffer(int size) Implements abstract org.
| |
| onClosed | back to summary |
|---|---|
| protected void onClosed() throws IOException Implements abstract org.
| |
| reallocateBuffer | back to summary |
|---|---|
| protected Buffer reallocateBuffer(Buffer oldBuffer, int size) Implements abstract org.
| |
| Modifier and Type | Field and Description |
|---|---|
| private final DefaultStreamWriter. | |
| private final CompletionHandler |
| Access | Constructor and Description |
|---|---|
| public | ResetCounterCompletionHandler(DefaultStreamWriter.
|
| Modifier and Type | Method and Description |
|---|---|
| public void | cancelled()
Implements org. The operation was cancelled. |
| public void | completed(Integer result)
Implements org. The operation was completed. |
| public void | failed(Throwable throwable)
Implements org. The operation was failed. |
| public void | updated(Integer result)
Implements org. The callback method may be called, when there is some progress in operation execution, but it is still not completed |
| output | back to summary |
|---|---|
| private final DefaultStreamWriter. | |
| parentCompletionHandler | back to summary |
|---|---|
| private final CompletionHandler<Integer> parentCompletionHandler | |
| ResetCounterCompletionHandler | back to summary |
|---|---|
| public ResetCounterCompletionHandler(DefaultStreamWriter. | |
| cancelled | back to summary |
|---|---|
| public void cancelled() Implements org. Doc from org. The operation was cancelled.
| |
| completed | back to summary |
|---|---|
| public void completed(Integer result) Implements org. Doc from org. The operation was completed.
| |
| failed | back to summary |
|---|---|
| public void failed(Throwable throwable) Implements org. Doc from org. The operation was failed.
| |
| updated | back to summary |
|---|---|
| public void updated(Integer result) Implements org. Doc from org. The callback method may be called, when there is some progress in operation execution, but it is still not completed
| |