Package io.micronaut.http.body.stream
package io.micronaut.http.body.stream
-
ClassDescription
AvailableByteBody
implementation based on a simple byte array.Base type for a shared buffer that distributes a singleBufferConsumer
input to multiple streamingByteBody
s.
The subclass handles concurrency (for netty, event loop) and the specific buffer type (for netty, ByteBuf).Body size limits.This is a reactor-like API for streaming bytes.This interface manages the backpressure for data consumptions.ByteBody
implementation that reads from an InputStream.BufferConsumer.Upstream
implementation that stores any inputs and thenforwards
them to another upstream later on.A subscriber that allows blocking reads from a publisher.This class merges the backpressure of two data streams.Pair ofBufferConsumer.Upstream
objects.