Package io.micronaut.http.body

Interface InternalByteBody

All Superinterfaces:

ByteBody

All Known Implementing Classes:

AvailableByteArrayBody, AvailableNettyByteBody, InputStreamByteBody, NettyByteBody, ReactiveByteBufferByteBody, StreamingNettyByteBody

@Internal
public interface InternalByteBody
extends ByteBody

Internal extensions of ByteBody.

Since:

4.5.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
default CompletableFuture<? extends CloseableAvailableByteBody>	buffer()	Buffer the full body and return an CompletableFuture that will complete when all bytes are available, or an error occurs.
@NonNull ExecutionFlow<? extends CloseableAvailableByteBody>	bufferFlow()	Variant of buffer() that uses the ExecutionFlow API for extra efficiency.
static ExecutionFlow<? extends CloseableAvailableByteBody>	bufferFlow(ByteBody body)

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

allowDiscard, expectedLength, move, split, split, toByteArrayPublisher, toByteBufferPublisher, toInputStream

Method Details

bufferFlow

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

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

Returns:

A flow that completes when all bytes are available

buffer

default CompletableFuture<? extends CloseableAvailableByteBody> buffer()

Description copied from interface: ByteBody

Buffer the full body and return an CompletableFuture that will complete when all bytes are available, or an error occurs.

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

Specified by:

buffer in interface ByteBody

Returns:

A future that completes when all bytes are available

bufferFlow

static ExecutionFlow<? extends CloseableAvailableByteBody> bufferFlow(ByteBody body)