Package io.micronaut.http.body.stream
package io.micronaut.http.body.stream
-
ClassDescription
AvailableByteBodyimplementation based on a simple byte array.Base type for a shared buffer that distributes a singleBufferConsumerinput to multiple streamingByteBodys.
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.ByteBodyimplementation that reads from an InputStream.BufferConsumer.Upstreamimplementation that stores any inputs and thenforwardsthem 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.Upstreamobjects.