Package io.micronaut.http.body.stream

package io.micronaut.http.body.stream

Related Packages

Package	Description
io.micronaut.http.body

Class	Description
AvailableByteArrayBody	AvailableByteBody implementation based on a simple byte array.
BaseSharedBuffer<C extends BufferConsumer,F>	Base type for a shared buffer that distributes a single BufferConsumer input to multiple streaming ByteBodys. The subclass handles concurrency (for netty, event loop) and the specific buffer type (for netty, ByteBuf).
BaseSharedBuffer.AsFlux<B>	BufferConsumer that can subscribe to a BaseSharedBuffer and return the buffer as a Flux.
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.
PublisherAsBlocking<T>	A subscriber that allows blocking reads from a publisher.
UpstreamBalancer	This class merges the backpressure of two data streams.
UpstreamBalancer.UpstreamPair	Pair of BufferConsumer.Upstream objects.