Package io.micronaut.http.body

Class ReactiveByteBufferByteBody

java.lang.Object

io.micronaut.http.body.InternalByteBody

io.micronaut.http.body.stream.BaseStreamingByteBody<ReactiveByteBufferByteBody.SharedBuffer>

io.micronaut.http.body.ReactiveByteBufferByteBody

All Implemented Interfaces:

ByteBody, CloseableByteBody, Closeable, AutoCloseable

@Internal
public final class ReactiveByteBufferByteBody
extends BaseStreamingByteBody<ReactiveByteBufferByteBody.SharedBuffer>
implements CloseableByteBody

Streaming ByteBody implementation based on NIO ByteBuffers.

Since:

4.8.0

Author:

Jonas Konrad

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ReactiveByteBufferByteBody.SharedBuffer	Simple implementation of BaseSharedBuffer that consumes ByteBuffers. Buffering is done using a ByteArrayOutputStream.

Nested classes/interfaces inherited from interface io.micronaut.http.body.ByteBody

ByteBody.BodyDiscardedException, ByteBody.SplitBackpressureMode

Field Summary

Fields inherited from class io.micronaut.http.body.stream.BaseStreamingByteBody

sharedBuffer, upstream

Constructor Summary

Constructors

Constructor	Description
ReactiveByteBufferByteBody(ReactiveByteBufferByteBody.SharedBuffer sharedBuffer)

Method Summary

Modifier and Type	Method	Description
@NonNull ExecutionFlow<? extends CloseableAvailableByteBody>	bufferFlow()	Variant of InternalByteBody.buffer() that uses the ExecutionFlow API for extra efficiency.
void	close()	Clean up any resources held by this instance.
protected ReactiveByteBufferByteBody	derive(BufferConsumer.Upstream upstream)	Create a new body instance on the same shared buffer with the given upstream.
BufferConsumer.Upstream	primary(BufferConsumer primary)	Consume this buffer.
@NonNull CloseableByteBody	split(@NonNull ByteBody.SplitBackpressureMode backpressureMode)	Create a new, independent ByteBody that contains the same data as this one.

Methods inherited from class io.micronaut.http.body.stream.BaseStreamingByteBody

allowDiscard, expectedLength, move, toInputStream, toReadBufferPublisher

Methods inherited from class io.micronaut.http.body.InternalByteBody

buffer, bufferFlow, failClaim, recordClosed, recordPrimaryOp, toByteArrayPublisher

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.http.body.ByteBody

buffer, expectedLength, move, split, toByteArrayPublisher, toByteBufferPublisher, toInputStream, toReadBufferPublisher, touch

Methods inherited from interface io.micronaut.http.body.CloseableByteBody

allowDiscard

Constructor Details

ReactiveByteBufferByteBody

public ReactiveByteBufferByteBody(ReactiveByteBufferByteBody.SharedBuffer sharedBuffer)

Method Details

primary

public BufferConsumer.Upstream primary(BufferConsumer primary)

Description copied from class: BaseStreamingByteBody

Consume this buffer.

Specified by:

primary in class BaseStreamingByteBody<ReactiveByteBufferByteBody.SharedBuffer>

Parameters:

primary - The consumer or null to discard the data

Returns:

The upstream to signal backpressure

derive

protected ReactiveByteBufferByteBody derive(BufferConsumer.Upstream upstream)

Description copied from class: BaseStreamingByteBody

Create a new body instance on the same shared buffer with the given upstream. This is used for BaseStreamingByteBody.move().

Specified by:

derive in class BaseStreamingByteBody<ReactiveByteBufferByteBody.SharedBuffer>

Parameters:

upstream - The upstream

Returns:

The body

split

@NonNull
public @NonNull CloseableByteBody split(@NonNull
 @NonNull ByteBody.SplitBackpressureMode backpressureMode)

Description copied from interface: ByteBody

Create a new, independent ByteBody that contains the same data as this one.

Specified by:

split in interface ByteBody

Parameters:

backpressureMode - How to handle backpressure between the old and new body. See ByteBody.SplitBackpressureMode documentation

Returns:

The newly split body. Must be closed by the caller, unless a terminal operation is performed on it

bufferFlow

@NonNull
public @NonNull ExecutionFlow<? extends CloseableAvailableByteBody> bufferFlow()

Description copied from class: InternalByteBody

Variant of InternalByteBody.buffer() that uses the ExecutionFlow API for extra efficiency.

Specified by:

bufferFlow in class InternalByteBody

Returns:

A flow that completes when all bytes are available

close

public void close()

Description copied from interface: CloseableByteBody

Clean up any resources held by this instance. See class documentation.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface CloseableByteBody