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).Thrown whenBaseSharedBuffer.complete()
is called beforeBaseSharedBuffer.getExpectedLength()
bytes are received.BaseStreamingByteBody<SB extends BaseSharedBuffer>Implementation of streamingByteBody
s based on aBaseSharedBuffer
.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.Transform aPublisherAsBlocking
of buffers into aInputStream
.This class merges the backpressure of two data streams.Pair ofBufferConsumer.Upstream
objects.