io.micronaut.http.server.netty

Class FormDataHttpContentProcessor

java.lang.Object

io.micronaut.core.async.subscriber.CompletionAwareSubscriber<T>

io.micronaut.core.async.processor.SingleSubscriberProcessor<io.netty.buffer.ByteBufHolder,T>

io.micronaut.http.server.netty.AbstractHttpContentProcessor<io.netty.handler.codec.http.multipart.HttpData>

io.micronaut.http.server.netty.FormDataHttpContentProcessor

All Implemented Interfaces:

Publishers.MicronautPublisher<io.netty.handler.codec.http.multipart.HttpData>, Completable, Emitter<io.netty.buffer.ByteBufHolder>, Toggleable, HttpContentProcessor<io.netty.handler.codec.http.multipart.HttpData>, org.reactivestreams.Processor<io.netty.buffer.ByteBufHolder,io.netty.handler.codec.http.multipart.HttpData>, org.reactivestreams.Publisher<io.netty.handler.codec.http.multipart.HttpData>, org.reactivestreams.Subscriber<io.netty.buffer.ByteBufHolder>

@Internal
public class FormDataHttpContentProcessor
extends AbstractHttpContentProcessor<io.netty.handler.codec.http.multipart.HttpData>

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 inherited from class io.micronaut.http.server.netty.AbstractHttpContentProcessor

advertisedLength, configuration, nettyHttpRequest, receivedLength, requestMaxSize

Fields inherited from class io.micronaut.core.async.processor.SingleSubscriberProcessor

EMPTY_SUBSCRIPTION, parentSubscription

Fields inherited from class io.micronaut.core.async.subscriber.CompletionAwareSubscriber

subscription

Method Summary

Modifier and Type	Method and Description
protected void	doAfterComplete() Called after SingleSubscriberProcessor.doOnComplete() completes.
protected void	doAfterOnError(java.lang.Throwable throwable) Called after SingleSubscriberProcessor.doOnError(Throwable) completes.
protected void	doOnSubscribe(org.reactivestreams.Subscription subscription, org.reactivestreams.Subscriber<? super io.netty.handler.codec.http.multipart.HttpData> subscriber) Perform the actual subscription to the subscriber.
boolean	isEnabled()
protected void	onData(io.netty.buffer.ByteBufHolder message) Called after verifying the data of the message.

Methods inherited from class io.micronaut.http.server.netty.AbstractHttpContentProcessor

doOnNext, doSubscribe, fireExceedsLength

Methods inherited from class io.micronaut.core.async.processor.SingleSubscriberProcessor

currentSubscriber, doAfterOnSubscribe, doOnComplete, doOnError, doOnSubscribe, getSubscriber, subscribe

Methods inherited from class io.micronaut.core.async.subscriber.CompletionAwareSubscriber

isComplete, onComplete, onError, onNext, onSubscribe

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.reactivestreams.Publisher

subscribe

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext, onSubscribe

Method Detail

isEnabled

public boolean isEnabled()

Returns:

Whether the component is enabled

doOnSubscribe

protected void doOnSubscribe(org.reactivestreams.Subscription subscription,
                             org.reactivestreams.Subscriber<? super io.netty.handler.codec.http.multipart.HttpData> subscriber)

Description copied from class: SingleSubscriberProcessor

Perform the actual subscription to the subscriber.

Overrides:

doOnSubscribe in class SingleSubscriberProcessor<io.netty.buffer.ByteBufHolder,io.netty.handler.codec.http.multipart.HttpData>

Parameters:

subscription - The subscription

subscriber - The subscriber (never null)

onData

protected void onData(io.netty.buffer.ByteBufHolder message)

Description copied from class: AbstractHttpContentProcessor

Called after verifying the data of the message.

Specified by:

onData in class AbstractHttpContentProcessor<io.netty.handler.codec.http.multipart.HttpData>

Parameters:

message - The message

doAfterOnError

protected void doAfterOnError(java.lang.Throwable throwable)

Description copied from class: SingleSubscriberProcessor

Called after SingleSubscriberProcessor.doOnError(Throwable) completes.

Overrides:

doAfterOnError in class SingleSubscriberProcessor<io.netty.buffer.ByteBufHolder,io.netty.handler.codec.http.multipart.HttpData>

Parameters:

throwable - The error

doAfterComplete

protected void doAfterComplete()

Description copied from class: SingleSubscriberProcessor

Called after SingleSubscriberProcessor.doOnComplete() completes.

Overrides:

doAfterComplete in class SingleSubscriberProcessor<io.netty.buffer.ByteBufHolder,io.netty.handler.codec.http.multipart.HttpData>