Package io.micronaut.http.netty.body

Class StreamingNettyByteBody

java.lang.Object

io.micronaut.http.netty.body.NettyByteBody

io.micronaut.http.netty.body.StreamingNettyByteBody

All Implemented Interfaces:

ByteBody, CloseableByteBody, InternalByteBody, Closeable, AutoCloseable

@Internal
public final class StreamingNettyByteBody
extends NettyByteBody
implements CloseableByteBody

Netty implementation for streaming ByteBody.

Since:

4.5.0

Author:

Jonas Konrad

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	StreamingNettyByteBody.SharedBuffer	This class buffers input data and distributes it to multiple StreamingNettyByteBody instances.

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

ByteBody.BodyDiscardedException, ByteBody.SplitBackpressureMode

Field Summary

Fields inherited from class io.micronaut.http.netty.body.NettyByteBody

LOG

Constructor Summary

Constructors

Constructor	Description
StreamingNettyByteBody(StreamingNettyByteBody.SharedBuffer sharedBuffer)

Method Summary

Modifier and Type	Method	Description
@NonNull StreamingNettyByteBody	allowDiscard()	Signal that the upstream may discard any remaining body data.
@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.
@NonNull OptionalLong	expectedLength()	Get the expected length of this body, if known (either from Content-Length or from previous buffering).
BufferConsumer.Upstream	primary(BufferConsumer primary)
@NonNull CloseableByteBody	split(@NonNull ByteBody.SplitBackpressureMode backpressureMode)	Create a new, independent ByteBody that contains the same data as this one.
protected reactor.core.publisher.Flux<io.netty.buffer.ByteBuf>	toByteBufPublisher()
@NonNull InputStream	toInputStream()	Get this body as an InputStream.

Methods inherited from class io.micronaut.http.netty.body.NettyByteBody

toByteArrayPublisher, toByteBufferPublisher, toByteBufs

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

split, toByteArrayPublisher, toByteBufferPublisher

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

buffer

Constructor Details

StreamingNettyByteBody

public StreamingNettyByteBody(StreamingNettyByteBody.SharedBuffer sharedBuffer)

Method Details

primary

public BufferConsumer.Upstream primary(BufferConsumer primary)

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

allowDiscard

@NonNull
public @NonNull StreamingNettyByteBody allowDiscard()

Description copied from interface: ByteBody

Signal that the upstream may discard any remaining body data. Only if all consumers of the body allow discarding will the body be discarded, otherwise it will still be sent to all consumers. It is an optional operation.

Discarding may be implemented e.g. by closing the input side of an HTTP/2 stream.

This method must be called before any primary operation.

Specified by:

allowDiscard in interface ByteBody

Specified by:

allowDiscard in interface CloseableByteBody

Returns:

This body

toByteBufPublisher

protected reactor.core.publisher.Flux<io.netty.buffer.ByteBuf> toByteBufPublisher()

expectedLength

@NonNull
public @NonNull OptionalLong expectedLength()

Description copied from interface: ByteBody

Get the expected length of this body, if known (either from Content-Length or from previous buffering). The actual length will never exceed this value, though it may sometimes be lower if there is a connection error.

This value may go from OptionalLong.empty() to a known value over the lifetime of this body.

This is not a primary operation and does not modify this ByteBody.

Specified by:

expectedLength in interface ByteBody

Returns:

The expected length of this body

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

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

Specified by:

bufferFlow in class NettyByteBody

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