Package org.eclipse.jetty.io

Class ChunkAccumulator

java.lang.Object

org.eclipse.jetty.io.ChunkAccumulator

public class ChunkAccumulator
extends Object

An accumulator of Content.Chunks used to facilitate minimal copy aggregation of multiple chunks.

Constructor Summary

Constructors

Constructor	Description
ChunkAccumulator()

Method Summary

Modifier and Type	Method	Description
boolean	add(Content.Chunk chunk)	Add a Content.Chunk to the accumulator.
void	close()
int	length()	Get the total length of the accumulated Content.Chunks.
CompletableFuture<byte[]>	readAll(Content.Source source)
CompletableFuture<byte[]>	readAll(Content.Source source, int maxSize)
CompletableFuture<RetainableByteBuffer>	readAll(Content.Source source, ByteBufferPool pool, boolean direct, int maxSize)
byte[]	take()
RetainableByteBuffer	take(ByteBufferPool pool, boolean direct)

Methods inherited from class java.lang.Object

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

Constructor Details

ChunkAccumulator

public ChunkAccumulator()

Method Details

add

public boolean add(Content.Chunk chunk)

Add a Content.Chunk to the accumulator.

Parameters:

chunk - The Content.Chunk to accumulate. If a reference is kept to the chunk (rather than a copy), it will be retained.

Returns:

true if the Content.Chunk had content and was added to the accumulator.

Throws:

ArithmeticException - if more that Integer.MAX_VALUE bytes are added.

IllegalArgumentException - if the passed Content.Chunk is a failure.

length

public int length()

Get the total length of the accumulated Content.Chunks.

Returns:

The total length in bytes.

take

public byte[] take()

take

public RetainableByteBuffer take(ByteBufferPool pool,
 boolean direct)

close

public void close()

readAll

public CompletableFuture<byte[]> readAll(Content.Source source)

readAll

public CompletableFuture<byte[]> readAll(Content.Source source,
 int maxSize)

readAll

public CompletableFuture<RetainableByteBuffer> readAll(Content.Source source,
 ByteBufferPool pool,
 boolean direct,
 int maxSize)

Parameters:

source - The Content.Source to read

pool - The ByteBufferPool to acquire the buffer from, or null for a non Retainable buffer

direct - True if the buffer should be direct.

maxSize - The maximum size to read, or -1 for no limit

Returns:

A CompletableFuture that will be completed when the complete content is read or failed if the max size is exceeded or there is a read error.