Package software.amazon.awssdk.core.internal.async

Class ChunkBuffer

java.lang.Object

software.amazon.awssdk.core.internal.async.ChunkBuffer

public final class ChunkBuffer
extends Object

Class that will buffer incoming BufferBytes to chunks of bufferSize. If totalBytes is not provided, i.e. content-length is unknown, getBufferedData() should be used in the Subscriber's onComplete() to check for a final chunk that is smaller than the chunk size, and send if present.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ChunkBuffer.Builder

Method Summary

Modifier and Type	Method	Description
static ChunkBuffer.Builder	builder()
Optional<ByteBuffer>	getBufferedData()	Retrieve the current buffered data.
Iterable<ByteBuffer>	split(ByteBuffer inputByteBuffer)	Split the input ByteBuffer into multiple smaller ByteBuffers, each of which contains chunkSize worth of bytes.

Methods inherited from class java.lang.Object

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

Method Details

builder

public static ChunkBuffer.Builder builder()

split

public Iterable<ByteBuffer> split(ByteBuffer inputByteBuffer)

Split the input ByteBuffer into multiple smaller ByteBuffers, each of which contains chunkSize worth of bytes. If the last chunk of the input ByteBuffer contains less than chunkSize data, the last chunk will be buffered.

getBufferedData

public Optional<ByteBuffer> getBufferedData()

Retrieve the current buffered data.