Package io.micronaut.http.body
package io.micronaut.http.body
-
ClassDescriptionAbstractBodyAdapter<B,
S extends BaseSharedBuffer<?, ?>> This is an extension ofByteBody
when the entire body is immediately available (without waiting).This class represents a stream of bytes from an HTTP connection.Exception that is sent to subscribers when the body is discarded as a result ofByteBody.allowDiscard()
calls.This enum controls how backpressure should be handled if one of the two bodies ("downstreams") is consuming data slower than the other.Factory methods forByteBody
s.Body writer forCharSequence
s.Variant ofMessageBodyReader
that allows piecewise reading of the input, e.g.Combination ofCloseableByteBody
andAvailableByteBody
.This is a reactive subscriber that acceptsByteBody
s and concatenates them into a singleBaseSharedBuffer
, optionally with separators.Concatenating implementation that writes to aReactiveByteBufferByteBody
.Concatenating implementation that writes to aReactiveByteBufferByteBody
, with JSON-style separators.MessageBodyHandlerRegistry
implementation that does not need an application context.Stores message body readers and writers.Internal extensions ofByteBody
.Interface for bodies that provide their own media type.A handler combines a reader and a writer.A registry ofMessageBodyReader
andMessageBodyWriter
.An interface that allows reading a message body from the client or the server.An interface that allows writing a message body for the client or the server.StreamingByteBody
implementation based on NIOByteBuffer
s.Simple implementation ofBaseSharedBuffer
that consumesByteBuffer
s.
Buffering is done using aByteArrayOutputStream
.Extension toMessageBodyWriter
that is specific to writing the server response body.The body reader forString
.The body reader that reads a text/plain string converting it into the argument type.A body handlerMessageBodyHandler
with a type argument.A body readerMessageBodyReader
with a type argument.A body writerMessageBodyWriter
with a type argument.Body writer forWritable
s.