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, 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

Constructor Details

FormDemuxer

public FormDemuxer(io.netty.contrib.multipart.PostBodyDecoder decoder,
 io.netty.channel.Channel channel,
 BodySizeLimits fieldLimits,
 BodySizeLimits totalLimits,
 ByteBody byteBody)

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