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