Package io.micronaut.http.body.stream

Class AvailableByteArrayBody

java.lang.Object

io.micronaut.http.body.stream.AvailableByteArrayBody

All Implemented Interfaces:

AvailableByteBody, ByteBody, CloseableAvailableByteBody, CloseableByteBody, InternalByteBody, Closeable, AutoCloseable

public final class AvailableByteArrayBody
extends Object
implements CloseableAvailableByteBody, InternalByteBody

AvailableByteBody implementation based on a simple byte array.

Since:

4.6.0

Author:

Jonas Konrad

Nested Class Summary

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

ByteBody.BodyDiscardedException, ByteBody.SplitBackpressureMode

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.
static @NonNull AvailableByteArrayBody	create(@NonNull ByteBufferFactory<?,?> bufferFactory, byte @NonNull [] array)
long	length()	The length in bytes of the body.
@NonNull CloseableByteBody	move()	Create a new CloseableByteBody with the same content but an independent lifecycle, claiming this body in the process.
@NonNull CloseableAvailableByteBody	split()	For immediate buffers, backpressure is not relevant, so the backpressure modes passed to AvailableByteBody.split(SplitBackpressureMode) are ignored.
byte @NonNull []	toByteArray()	Get this body as a byte array.
@NonNull ByteBuffer<?>	toByteBuffer()	Get this body as a ByteBuffer.
@NonNull InputStream	toInputStream()	Get this body as an InputStream.

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.AvailableByteBody

expectedLength, split, toByteArrayPublisher, toByteBufferPublisher, toString

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

allowDiscard

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

buffer

Method Details

create

@NonNull
public static @NonNull AvailableByteArrayBody create(@NonNull
 @NonNull ByteBufferFactory<?,?> bufferFactory,
 byte @NonNull [] array)

split

@NonNull
public @NonNull CloseableAvailableByteBody split()

Description copied from interface: AvailableByteBody

For immediate buffers, backpressure is not relevant, so the backpressure modes passed to AvailableByteBody.split(SplitBackpressureMode) are ignored. You can use this method always.

Specified by:

split in interface AvailableByteBody

Specified by:

split in interface ByteBody

Returns:

A body with the same content as this one

See Also:

• ByteBody.split()

toInputStream

@NonNull
public @NonNull InputStream toInputStream()

Description copied from interface: ByteBody

Get this body as an InputStream.

This is a primary operation. After this operation, no other primary operation or ByteBody.split() may be done.

Specified by:

toInputStream in interface ByteBody

Returns:

The streamed bytes

length

public long length()

Description copied from interface: AvailableByteBody

The length in bytes of the body.

Specified by:

length in interface AvailableByteBody

Returns:

The length

See Also:

• ByteBody.expectedLength()

toByteArray

public byte @NonNull [] toByteArray()

Description copied from interface: AvailableByteBody

Get this body as a byte array.

This is a primary operation. After this operation, no other primary operation or AvailableByteBody.split() may be done.

Specified by:

toByteArray in interface AvailableByteBody

Returns:

The bytes

toByteBuffer

@NonNull
public @NonNull ByteBuffer<?> toByteBuffer()

Description copied from interface: AvailableByteBody

Get this body as a ByteBuffer. Note that the buffer may be reference counted, and the caller must take care of releasing it.

This is a primary operation. After this operation, no other primary operation or AvailableByteBody.split() may be done.

Specified by:

toByteBuffer in interface AvailableByteBody

Returns:

The bytes

move

@NonNull
public @NonNull CloseableByteBody move()

Description copied from interface: ByteBody

Create a new CloseableByteBody with the same content but an independent lifecycle, claiming this body in the process.

This is a primary operation. After this operation, no other primary operation or ByteBody.split() may be done.

The purpose of this method is to move the data to a different component in an application, making clear that the receiving component claims ownership of the body. If the sending component then closes the original ByteBody for example, it will have no impact on the new CloseableByteBody that the receiver is working with.

Specified by:

move in interface ByteBody

Returns:

A new CloseableByteBody with the same content.

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

bufferFlow

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

Description copied from interface: InternalByteBody

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

Specified by:

bufferFlow in interface InternalByteBody

Returns:

A flow that completes when all bytes are available