Package org.eclipse.jetty.io.content

Class BufferedContentSink

java.lang.Object

org.eclipse.jetty.io.content.BufferedContentSink

All Implemented Interfaces:

Content.Sink

public class BufferedContentSink
extends Object
implements Content.Sink

A Content.Sink backed by another Content.Sink. Any content written to this Content.Sink is buffered, then written to the delegate using Content.Sink.write(boolean, ByteBuffer, Callback).

Field Summary

Fields

Modifier and Type	Field	Description
static final ByteBuffer	FLUSH_BUFFER	An empty ByteBuffer, which if written will invoke a flush(Callback) operation.

Constructor Summary

Constructors

Constructor	Description
BufferedContentSink(Content.Sink delegate, ByteBufferPool bufferPool, boolean direct, int maxAggregationSize, int maxBufferSize)

Method Summary

Modifier and Type	Method	Description
void	flush(Callback callback)	Flush the buffered content.
void	write(boolean last, ByteBuffer byteBuffer, Callback callback)	Writes the given ByteBuffer, notifying the Callback when the write is complete.

Methods inherited from class java.lang.Object

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

Field Details

FLUSH_BUFFER

public static final ByteBuffer FLUSH_BUFFER

An empty ByteBuffer, which if written will invoke a flush(Callback) operation.

Constructor Details

BufferedContentSink

public BufferedContentSink(Content.Sink delegate,
 ByteBufferPool bufferPool,
 boolean direct,
 int maxAggregationSize,
 int maxBufferSize)

Method Details

write

public void write(boolean last,
 ByteBuffer byteBuffer,
 Callback callback)

Description copied from interface: Content.Sink

Writes the given ByteBuffer, notifying the Callback when the write is complete.

Implementations guarantee that calls to this method are safely reentrant so that stack overflows are avoided in the case of mutual recursion between the execution of the Callback and a call to this method.

Specified by:

write in interface Content.Sink

Parameters:

last - whether the ByteBuffer is the last to write

byteBuffer - the ByteBuffer to write

callback - the callback to notify when the write operation is complete

flush

public void flush(Callback callback)

Flush the buffered content.

Parameters:

callback - Callback completed when the flush is complete