io.micronaut.xml.jackson.server

Class XmlContentProcessor

java.lang.Object

io.micronaut.core.async.subscriber.SingleThreadedBufferingSubscriber<R>

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

io.micronaut.http.server.netty.AbstractBufferingHttpContentProcessor<java.lang.Object>

io.micronaut.xml.jackson.server.XmlContentProcessor

All Implemented Interfaces:

io.micronaut.core.async.subscriber.Completable, io.micronaut.core.async.subscriber.Emitter<io.netty.buffer.ByteBufHolder>, io.micronaut.core.util.Toggleable, io.micronaut.http.server.netty.HttpContentProcessor<java.lang.Object>, org.reactivestreams.Processor<io.netty.buffer.ByteBufHolder,java.lang.Object>, org.reactivestreams.Publisher<java.lang.Object>, org.reactivestreams.Subscriber<io.netty.buffer.ByteBufHolder>

public class XmlContentProcessor
extends io.micronaut.http.server.netty.AbstractBufferingHttpContentProcessor<java.lang.Object>

This class will handle subscribing to a Xml stream and binding once the events are complete in a non-blocking manner.

Since:

1.0.0

Author:

Sergey Vishnyakov, James Kleeh

Nested Class Summary

Nested classes/interfaces inherited from class io.micronaut.core.async.subscriber.SingleThreadedBufferingSubscriber

io.micronaut.core.async.subscriber.SingleThreadedBufferingSubscriber.BackPressureState, io.micronaut.core.async.subscriber.SingleThreadedBufferingSubscriber.DownstreamSubscription

Field Summary

Fields inherited from class io.micronaut.http.server.netty.AbstractBufferingHttpContentProcessor

advertisedLength, configuration, nettyHttpRequest, receivedLength, requestMaxSize

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

upstreamBuffer, upstreamDemand, upstreamState, upstreamSubscription

Constructor Summary

Constructors

Constructor and Description
XmlContentProcessor(io.micronaut.http.server.netty.NettyHttpRequest<?> nettyHttpRequest, io.micronaut.http.server.HttpServerConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
protected void	doOnComplete()
protected void	onUpstreamMessage(io.netty.buffer.ByteBufHolder message)
void	subscribe(org.reactivestreams.Subscriber<? super java.lang.Object> downstreamSubscriber)

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

doOnNext, fireExceedsLength, verifyPartDefinedSize

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

currentDownstreamSubscriber, doOnError, doOnSubscribe, getDownstreamSubscriber, subscribeDownstream

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

newDownstreamSubscription, onComplete, onError, onNext, onSubscribe, provideDownstreamSubscription

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext, onSubscribe

Methods inherited from interface io.micronaut.core.util.Toggleable

isEnabled

Constructor Detail

XmlContentProcessor

public XmlContentProcessor(io.micronaut.http.server.netty.NettyHttpRequest<?> nettyHttpRequest,
                           io.micronaut.http.server.HttpServerConfiguration configuration)

Parameters:

nettyHttpRequest - The NettyHttpRequest

configuration - The HttpServerConfiguration

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super java.lang.Object> downstreamSubscriber)

Specified by:

subscribe in interface org.reactivestreams.Publisher<java.lang.Object>

Overrides:

subscribe in class io.micronaut.http.server.netty.AbstractBufferingHttpContentProcessor<java.lang.Object>

onUpstreamMessage

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

Specified by:

onUpstreamMessage in class io.micronaut.core.async.processor.SingleThreadedBufferingProcessor<io.netty.buffer.ByteBufHolder,java.lang.Object>

doOnComplete

protected void doOnComplete()

Overrides:

doOnComplete in class io.micronaut.core.async.processor.SingleThreadedBufferingProcessor<io.netty.buffer.ByteBufHolder,java.lang.Object>