Package io.micronaut.http.server.netty
package io.micronaut.http.server.netty
Netty server classes for Micronaut.
- Since:
- 1.0
- Author:
- Graeme Rocher
-
ClassDescriptionAbstract implementation of the
HttpContentProcessor
interface that deals with limiting file upload sizes.Delegates all functionality to the provided buffer.This class will handle subscribing to a stream ofHttpContent
.Default implementation that determines if the body argument (if present) does not expect decoding of the request body, that theDefaultHttpContentProcessor
should be used, regardless of the content type of the request.Default implementation ofNettyEmbeddedServerFactory
.Delegate for Streamed HTTP Response.DecodesMediaType.MULTIPART_FORM_DATA
in a non-blocking manner.SpecialHttpBody
that "demultiplexes" form data.Determines if a given http message should be compressed.Deprecated.Utility class for transforming aNettyHttpRequest
using aHttpContentProcessor
to aPublisher
.
Note: A more complicated, but possibly faster, implementation of this class is archived in the original PR.Responsible for determining whichHttpContentProcessor
to use to process the body of the request.Interface that allows plugging into the constructor of theHttpContent
subscriber.MicronautHttpData<D extends io.netty.handler.codec.http.multipart.HttpData>AlternateHttpData
implementation with some limited concurrency support.Factory forMicronautHttpData
instances.ExtendedEmbeddedServer
interface that represents a Netty-based HTTP server.A factory / strategy interface for creating instances ofNettyEmbeddedServer
.Internal interface with services required by theNettyHttpServer
.Delegates to the NettyHttpRequest
instance.Implementation ofHttpResponseFactory
for Netty.Implements the bootstrap and configuration logic for the Netty implementation ofEmbeddedServer
.Interface implemented by users to hook into the pipeline setup of the netty HTTP server.Enum to describe the role of the channel passed toNettyServerCustomizer.specializeForChannel(Channel, ChannelRole)
.Interface implemented by the HTTP server to register customizers.Internal implementation of theChannelInboundHandler
for Micronaut.An extension ofHttpContentCompressor
that skips encoding if the content type is not compressible or if the content is too small.
MessageBodyReader
API instead