Class FragmentingFlusher

java.lang.Object

org.eclipse.jetty.websocket.core.util.WebSocketFlusher

org.eclipse.jetty.websocket.core.util.FragmentingFlusher

All Implemented Interfaces:

OutgoingFrames

public abstract class FragmentingFlusher
extends WebSocketFlusher

Used to split large data frames into multiple frames below the maxFrameSize. Control frames and dataFrames smaller than the maxFrameSize will be forwarded directly to forwardFrame(OutgoingEntry).

Constructor Summary

Constructors

Constructor	Description
FragmentingFlusher(Configuration configuration)

Method Summary

Modifier and Type	Method	Description
protected abstract void	forwardFrame(OutgoingEntry entry)
protected void	onCompleteFailure(Throwable cause)	Called when the flusher has failed and WebSocketFlusher.onFrame(OutgoingEntry, boolean) will never be called again.
protected boolean	onFrame(OutgoingEntry entry, boolean first)	Called when a frame is ready to be transformed.

Methods inherited from class WebSocketFlusher

closeFlusher, failFlusher, sendFrame

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface OutgoingFrames

sendFrame

Constructor Details

FragmentingFlusher

public FragmentingFlusher(Configuration configuration)

Method Details

forwardFrame

protected abstract void forwardFrame(OutgoingEntry entry)

onFrame

protected boolean onFrame(OutgoingEntry entry,
 boolean first)

Description copied from class: WebSocketFlusher

Called when a frame is ready to be transformed.

Specified by:

onFrame in class WebSocketFlusher

Parameters:

entry - the entry containing the frame to be transformed.

first - true if this is the first time this entry is being processed.

Returns:

true to indicate that you have finished transforming this entry.

onCompleteFailure

protected void onCompleteFailure(Throwable cause)

Description copied from class: WebSocketFlusher

Called when the flusher has failed and WebSocketFlusher.onFrame(OutgoingEntry, boolean) will never be called again.

Overrides:

onCompleteFailure in class WebSocketFlusher