Package io.micronaut.http.server.netty

Class FormDataHttpContentProcessor

java.lang.Object

io.micronaut.http.server.netty.FormDataHttpContentProcessor

@Internal
public final class FormDataHttpContentProcessor
extends Object

Decodes MediaType.MULTIPART_FORM_DATA in a non-blocking manner.

Designed to be used by a single thread

Since:

1.0

Author:

Graeme Rocher

Field Summary

Fields

Modifier and Type	Field	Description
protected final long	advertisedLength
protected final NettyHttpServerConfiguration	configuration
protected final NettyHttpRequest<?>	nettyHttpRequest
protected final AtomicLong	receivedLength
protected final long	requestMaxSize

Constructor Summary

Constructors

Constructor	Description
FormDataHttpContentProcessor(NettyHttpRequest<?> nettyHttpRequest, NettyHttpServerConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
void	add(io.netty.buffer.ByteBufHolder message, Collection<? super io.netty.handler.codec.http.multipart.InterfaceHttpData> out)
void	cancel()
void	complete(Collection<? super io.netty.handler.codec.http.multipart.InterfaceHttpData> out)
protected void	fireExceedsLength(long receivedLength, long expected, io.netty.buffer.ByteBufHolder message)
protected void	onData(io.netty.buffer.ByteBufHolder message, Collection<? super io.netty.handler.codec.http.multipart.InterfaceHttpData> out)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

nettyHttpRequest

protected final NettyHttpRequest<?> nettyHttpRequest

advertisedLength

protected final long advertisedLength

requestMaxSize

protected final long requestMaxSize

receivedLength

protected final AtomicLong receivedLength

configuration

protected final NettyHttpServerConfiguration configuration

Constructor Details

FormDataHttpContentProcessor

public FormDataHttpContentProcessor(NettyHttpRequest<?> nettyHttpRequest,
 NettyHttpServerConfiguration configuration)

Parameters:

nettyHttpRequest - The NettyHttpRequest

configuration - The NettyHttpServerConfiguration

Method Details

onData

protected void onData(io.netty.buffer.ByteBufHolder message,
 Collection<? super io.netty.handler.codec.http.multipart.InterfaceHttpData> out)

add

public void add(io.netty.buffer.ByteBufHolder message,
 Collection<? super io.netty.handler.codec.http.multipart.InterfaceHttpData> out)
         throws Throwable

Throws:

Throwable

complete

public void complete(Collection<? super io.netty.handler.codec.http.multipart.InterfaceHttpData> out)
              throws Throwable

Throws:

Throwable

cancel

public void cancel()

fireExceedsLength

protected void fireExceedsLength(long receivedLength,
 long expected,
 io.netty.buffer.ByteBufHolder message)

Parameters:

receivedLength - The length of the content received

expected - The expected length of the content

message - The message to release