@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
advertisedLength, configuration, nettyHttpRequest, receivedLength, requestMaxSize
EMPTY_SUBSCRIPTION, parentSubscription
subscription
Modifier and Type | Method and Description |
---|---|
protected void |
doAfterComplete()
Called after
SingleSubscriberProcessor.doOnComplete() completes. |
protected void |
doAfterOnError(Throwable throwable)
Called after
SingleSubscriberProcessor.doOnError(Throwable) completes. |
protected void |
doOnSubscribe(Subscription subscription,
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.
|
doOnNext, doSubscribe
currentSubscriber, doAfterOnSubscribe, doOnComplete, doOnError, doOnSubscribe, getSubscriber, subscribe
isComplete, onComplete, onError, onNext, onSubscribe
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onComplete, onError, onNext, onSubscribe
public boolean isEnabled()
protected void doOnSubscribe(Subscription subscription, Subscriber<? super io.netty.handler.codec.http.multipart.HttpData> subscriber)
SingleSubscriberProcessor
doOnSubscribe
in class SingleSubscriberProcessor<io.netty.buffer.ByteBufHolder,io.netty.handler.codec.http.multipart.HttpData>
subscription
- The subscriptionsubscriber
- The subscriber (never null)protected void onData(io.netty.buffer.ByteBufHolder message)
AbstractHttpContentProcessor
onData
in class AbstractHttpContentProcessor<io.netty.handler.codec.http.multipart.HttpData>
message
- The messageprotected void doAfterOnError(Throwable throwable)
SingleSubscriberProcessor
SingleSubscriberProcessor.doOnError(Throwable)
completes.doAfterOnError
in class SingleSubscriberProcessor<io.netty.buffer.ByteBufHolder,io.netty.handler.codec.http.multipart.HttpData>
throwable
- The errorprotected void doAfterComplete()
SingleSubscriberProcessor
SingleSubscriberProcessor.doOnComplete()
completes.doAfterComplete
in class SingleSubscriberProcessor<io.netty.buffer.ByteBufHolder,io.netty.handler.codec.http.multipart.HttpData>