Class CompressExtension.Flusher
- java.lang.Object
-
- org.eclipse.jetty.util.IteratingCallback
-
- org.eclipse.jetty.websocket.common.extensions.compress.CompressExtension.Flusher
-
- All Implemented Interfaces:
org.eclipse.jetty.util.Callback
,org.eclipse.jetty.util.thread.Invocable
,WriteCallback
- Enclosing class:
- CompressExtension
private class CompressExtension.Flusher extends org.eclipse.jetty.util.IteratingCallback implements WriteCallback
-
-
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 private CompressExtension.FrameEntry
current
private boolean
finished
-
Constructor Summary
Constructors Modifier Constructor Description private
Flusher()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
compress(CompressExtension.FrameEntry entry, boolean first)
private void
deflate(CompressExtension.FrameEntry entry)
void
failed(java.lang.Throwable x)
protected void
onCompleteFailure(java.lang.Throwable x)
protected void
onCompleteSuccess()
protected org.eclipse.jetty.util.IteratingCallback.Action
process()
void
writeFailed(java.lang.Throwable x)
Callback invoked when the write fails.void
writeSuccess()
Callback invoked when the write completes.-
Methods inherited from class org.eclipse.jetty.util.IteratingCallback
close, isClosed, isFailed, isSucceeded, iterate, reset, succeeded, toString
-
-
-
-
Field Detail
-
current
private CompressExtension.FrameEntry current
-
finished
private boolean finished
-
-
Method Detail
-
failed
public void failed(java.lang.Throwable x)
- Specified by:
failed
in interfaceorg.eclipse.jetty.util.Callback
- Overrides:
failed
in classorg.eclipse.jetty.util.IteratingCallback
-
process
protected org.eclipse.jetty.util.IteratingCallback.Action process() throws java.lang.Exception
- Specified by:
process
in classorg.eclipse.jetty.util.IteratingCallback
- Throws:
java.lang.Exception
-
deflate
private void deflate(CompressExtension.FrameEntry entry)
-
compress
private void compress(CompressExtension.FrameEntry entry, boolean first)
-
onCompleteSuccess
protected void onCompleteSuccess()
- Overrides:
onCompleteSuccess
in classorg.eclipse.jetty.util.IteratingCallback
-
onCompleteFailure
protected void onCompleteFailure(java.lang.Throwable x)
- Overrides:
onCompleteFailure
in classorg.eclipse.jetty.util.IteratingCallback
-
writeSuccess
public void writeSuccess()
Description copied from interface:WriteCallback
Callback invoked when the write completes.
- Specified by:
writeSuccess
in interfaceWriteCallback
- See Also:
WriteCallback.writeFailed(Throwable)
-
writeFailed
public void writeFailed(java.lang.Throwable x)
Description copied from interface:WriteCallback
Callback invoked when the write fails.
- Specified by:
writeFailed
in interfaceWriteCallback
- Parameters:
x
- the reason for the write failure
-
-