Package io.micronaut.http.body.stream

@NullMarked package io.micronaut.http.body.stream

The package info.

Related Packages

Package	Description
io.micronaut.http.body	The package info.

Class	Description
AvailableByteArrayBody	AvailableByteBody implementation based on a simple byte array.
BaseSharedBuffer	Base type for a shared buffer that distributes a single BufferConsumer input to multiple streaming ByteBodys. The subclass handles concurrency (for netty, event loop).
BaseSharedBuffer.AsFlux	BufferConsumer that can subscribe to a BaseSharedBuffer and return the buffer as a Flux.
BaseSharedBuffer.IncorrectContentLengthException	Thrown when BaseSharedBuffer.complete() is called before BaseSharedBuffer.getExpectedLength() bytes are received.
BaseStreamingByteBody<SB extends BaseSharedBuffer>	Implementation of streaming ByteBodys based on a BaseSharedBuffer.
BodySizeLimits	Body size limits.
BufferConsumer	This is a reactor-like API for streaming bytes.
BufferConsumer.Upstream	This interface manages the backpressure for data consumptions.
InputStreamByteBody	ByteBody implementation that reads from an InputStream.
LazyUpstream	BufferConsumer.Upstream implementation that stores any inputs and then forwards them to another upstream later on.
PublisherAsBlocking	A subscriber that allows blocking reads from a publisher.
PublisherAsStream	Transform a PublisherAsBlocking of buffers into a InputStream.
UpstreamBalancer	This class merges the backpressure of two data streams.
UpstreamBalancer.UpstreamPair	Pair of BufferConsumer.Upstream objects.