private class AbstractWebSocketConnection.Flusher extends FrameFlusher
IteratingCallback.Action
Callback.Completable, Callback.Completing, Callback.Nested
Invocable.InvocationType
FLUSH_FRAME
__nonBlocking
Modifier | Constructor and Description |
---|---|
private |
Flusher(ByteBufferPool bufferPool,
Generator generator,
EndPoint endpoint) |
Modifier and Type | Method and Description |
---|---|
void |
onCompleteFailure(java.lang.Throwable failure)
Invoked when the overall task has completed with a failure.
|
enqueue, getBytesOut, getMessagesOut, notifyCallbackFailure, notifyCallbackSuccess, process, succeeded, terminate, toString
close, failed, isClosed, isFailed, isSucceeded, iterate, onCompleteSuccess, reset
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getInvocationType, getInvocationType, invokeNonBlocking, isNonBlockingInvocation
private Flusher(ByteBufferPool bufferPool, Generator generator, EndPoint endpoint)
public void onCompleteFailure(java.lang.Throwable failure)
IteratingCallback
onCompleteFailure
in class FrameFlusher
failure
- the throwable to indicate cause of failureIteratingCallback.onCompleteSuccess()