Class FormDemuxer

java.lang.Object

io.micronaut.http.server.netty.multipart.FormDemuxer

All Implemented Interfaces:

BufferConsumer

@Internal
public final class FormDemuxer
extends Object
implements BufferConsumer

This class parses a ByteBody into a sequence of RawFormFields.

Since:

5.0.0

Author:

Jonas Konrad

Nested Class Summary

Nested classes/interfaces inherited from interface BufferConsumer

BufferConsumer.Upstream

Constructor Summary

Constructors

Constructor	Description
FormDemuxer(io.netty.contrib.multipart.PostBodyDecoder decoder, @Nullable String multipartBoundary, Charset charset, io.netty.channel.Channel channel, BodySizeLimits fieldLimits, BodySizeLimits totalLimits, ByteBody byteBody)

Method Summary

Modifier and Type	Method	Description
void	add(ReadBuffer rb)	Send a buffer to this consumer.
void	complete()	Signal normal completion of the stream.
void	discard()	Signal that the upstream has discarded the remaining data, as requested by BufferConsumer.Upstream.allowDiscard().
void	error(Throwable e)	Signal an upstream error.
reactor.core.publisher.Flux<RawFormField>	fields()

Methods inherited from class Object

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

Methods inherited from interface BufferConsumer

addAndComplete

Constructor Details

FormDemuxer

public FormDemuxer(io.netty.contrib.multipart.PostBodyDecoder decoder,
 @Nullable
 @Nullable String multipartBoundary,
 Charset charset,
 io.netty.channel.Channel channel,
 BodySizeLimits fieldLimits,
 BodySizeLimits totalLimits,
 ByteBody byteBody)

Parameters:

decoder - The decoder

multipartBoundary - The boundary of a multipart body, whose close delimiter must end the body: a body that ends before it, e.g. a truncated upload, fails like a malformed body. null for a body without one, e.g. URL-encoded data

charset - The charset of the decoder, which it encodes the boundary with

channel - The channel

fieldLimits - The limits of a field

totalLimits - The limits of the form

byteBody - The body

Method Details

fields

public reactor.core.publisher.Flux<RawFormField> fields()

add

public void add(ReadBuffer rb)

Description copied from interface: BufferConsumer

Send a buffer to this consumer. Ownership of the buffer transfers to the consumer.

Specified by:

add in interface BufferConsumer

Parameters:

rb - The buffer

complete

public void complete()

Description copied from interface: BufferConsumer

Signal normal completion of the stream.

Specified by:

complete in interface BufferConsumer

discard

public void discard()

Description copied from interface: BufferConsumer

Signal that the upstream has discarded the remaining data, as requested by BufferConsumer.Upstream.allowDiscard().

Specified by:

discard in interface BufferConsumer

error

public void error(Throwable e)

Description copied from interface: BufferConsumer

Signal an upstream error.

Specified by:

error in interface BufferConsumer

Parameters:

e - The error