@Internal public class JsonContentProcessor extends AbstractHttpContentProcessor<JsonNode>
advertisedLength, configuration, nettyHttpRequest, receivedLength, requestMaxSize
EMPTY_SUBSCRIPTION, parentSubscription
subscription
Constructor and Description |
---|
JsonContentProcessor(NettyHttpRequest<?> nettyHttpRequest,
HttpServerConfiguration configuration,
JsonMapper jsonMapper) |
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.
|
doOnNext, doSubscribe, fireExceedsLength
currentSubscriber, doAfterComplete, doAfterOnSubscribe, doOnError, doOnSubscribe, getSubscriber, subscribe
isComplete, onComplete, onError, onNext, onSubscribe
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onComplete, onError, onNext, onSubscribe
isEnabled
public JsonContentProcessor(NettyHttpRequest<?> nettyHttpRequest, HttpServerConfiguration configuration, JsonMapper jsonMapper)
nettyHttpRequest
- The Netty Http requestconfiguration
- The Http server configurationjsonMapper
- The json codecprotected void doOnSubscribe(Subscription subscription, Subscriber<? super JsonNode> subscriber)
SingleSubscriberProcessor
doOnSubscribe
in class SingleSubscriberProcessor<io.netty.buffer.ByteBufHolder,JsonNode>
subscription
- The subscriptionsubscriber
- The subscriber (never null)protected void onData(io.netty.buffer.ByteBufHolder message)
AbstractHttpContentProcessor
onData
in class AbstractHttpContentProcessor<JsonNode>
message
- The messageprotected void doAfterOnError(Throwable throwable)
SingleSubscriberProcessor
SingleSubscriberProcessor.doOnError(Throwable)
completes.doAfterOnError
in class SingleSubscriberProcessor<io.netty.buffer.ByteBufHolder,JsonNode>
throwable
- The errorprotected void doOnComplete()
CompletionAwareSubscriber
Subscriber.onComplete()
.doOnComplete
in class SingleSubscriberProcessor<io.netty.buffer.ByteBufHolder,JsonNode>