Class FrameFlusher
- java.lang.Object
-
- org.eclipse.jetty.util.IteratingCallback
-
- org.eclipse.jetty.websocket.common.io.FrameFlusher
-
- All Implemented Interfaces:
org.eclipse.jetty.util.Callback
,org.eclipse.jetty.util.thread.Invocable
public class FrameFlusher extends org.eclipse.jetty.util.IteratingCallback
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.eclipse.jetty.util.IteratingCallback
org.eclipse.jetty.util.IteratingCallback.Action
-
-
Field Summary
Fields Modifier and Type Field Description static BinaryFrame
FLUSH_FRAME
-
Constructor Summary
Constructors Constructor Description FrameFlusher(org.eclipse.jetty.io.ByteBufferPool bufferPool, Generator generator, org.eclipse.jetty.io.EndPoint endPoint, int bufferSize, int maxGather)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
enqueue(Frame frame, WriteCallback callback, BatchMode batchMode)
long
getBytesOut()
long
getMessagesOut()
protected void
notifyCallbackFailure(WriteCallback callback, java.lang.Throwable failure)
protected void
notifyCallbackSuccess(WriteCallback callback)
void
onCompleteFailure(java.lang.Throwable failure)
protected org.eclipse.jetty.util.IteratingCallback.Action
process()
void
succeeded()
java.lang.String
toString()
-
Methods inherited from class org.eclipse.jetty.util.IteratingCallback
close, failed, isClosed, isFailed, isSucceeded, iterate, onCompleteSuccess, reset
-
-
-
-
Field Detail
-
FLUSH_FRAME
public static final BinaryFrame FLUSH_FRAME
-
-
Constructor Detail
-
FrameFlusher
public FrameFlusher(org.eclipse.jetty.io.ByteBufferPool bufferPool, Generator generator, org.eclipse.jetty.io.EndPoint endPoint, int bufferSize, int maxGather)
-
-
Method Detail
-
enqueue
public boolean enqueue(Frame frame, WriteCallback callback, BatchMode batchMode)
-
process
protected org.eclipse.jetty.util.IteratingCallback.Action process() throws java.lang.Throwable
- Specified by:
process
in classorg.eclipse.jetty.util.IteratingCallback
- Throws:
java.lang.Throwable
-
succeeded
public void succeeded()
- Specified by:
succeeded
in interfaceorg.eclipse.jetty.util.Callback
- Overrides:
succeeded
in classorg.eclipse.jetty.util.IteratingCallback
-
onCompleteFailure
public void onCompleteFailure(java.lang.Throwable failure)
- Overrides:
onCompleteFailure
in classorg.eclipse.jetty.util.IteratingCallback
-
notifyCallbackSuccess
protected void notifyCallbackSuccess(WriteCallback callback)
-
notifyCallbackFailure
protected void notifyCallbackFailure(WriteCallback callback, java.lang.Throwable failure)
-
getMessagesOut
public long getMessagesOut()
-
getBytesOut
public long getBytesOut()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classorg.eclipse.jetty.util.IteratingCallback
-
-