io.micronaut.http.server.netty.jackson

Class JsonContentProcessor

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

io.micronaut.http.server.netty.jackson.JsonContentProcessor

All Implemented Interfaces:

Publishers.MicronautPublisher<JsonNode>, Completable, Emitter<io.netty.buffer.ByteBufHolder>, Toggleable, HttpContentProcessor<JsonNode>, Processor<io.netty.buffer.ByteBufHolder,JsonNode>, Publisher<JsonNode>, Subscriber<io.netty.buffer.ByteBufHolder>

@Internal
public class JsonContentProcessor
extends AbstractHttpContentProcessor<JsonNode>

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

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

Constructor Summary

Constructors

Constructor and Description
JsonContentProcessor(NettyHttpRequest<?> nettyHttpRequest, HttpServerConfiguration configuration, JsonMapper jsonMapper)

Method Summary

Modifier and Type	Method and Description
protected void	doAfterOnError(Throwable throwable) Called after SingleSubscriberProcessor.doOnError(Throwable) completes.
protected void	doOnComplete() Implement Subscriber.onComplete().
protected void	doOnSubscribe(Subscription subscription, Subscriber<? super JsonNode> subscriber) Perform the actual subscription to the subscriber.
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, doAfterComplete, doAfterOnSubscribe, 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

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

isEnabled

Constructor Detail

JsonContentProcessor

public JsonContentProcessor(NettyHttpRequest<?> nettyHttpRequest,
                            HttpServerConfiguration configuration,
                            JsonMapper jsonMapper)

Parameters:

nettyHttpRequest - The Netty Http request

configuration - The Http server configuration

jsonMapper - The json codec

Method Detail

doOnSubscribe

protected void doOnSubscribe(Subscription subscription,
                             Subscriber<? super JsonNode> subscriber)

Description copied from class: SingleSubscriberProcessor

Perform the actual subscription to the subscriber.

Overrides:

doOnSubscribe in class SingleSubscriberProcessor<io.netty.buffer.ByteBufHolder,JsonNode>

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

Parameters:

message - The message

doAfterOnError

protected void doAfterOnError(Throwable throwable)

Description copied from class: SingleSubscriberProcessor

Called after SingleSubscriberProcessor.doOnError(Throwable) completes.

Overrides:

doAfterOnError in class SingleSubscriberProcessor<io.netty.buffer.ByteBufHolder,JsonNode>

Parameters:

throwable - The error

doOnComplete

protected void doOnComplete()

Description copied from class: CompletionAwareSubscriber

Implement Subscriber.onComplete().

Overrides:

doOnComplete in class SingleSubscriberProcessor<io.netty.buffer.ByteBufHolder,JsonNode>