io.micronaut.http.server.netty

Class AbstractHttpContentProcessor<T>

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

Type Parameters:

T - The type

All Implemented Interfaces:

Completable, Emitter<io.netty.buffer.ByteBufHolder>, Toggleable, HttpContentProcessor<T>, Processor<io.netty.buffer.ByteBufHolder,T>, Publisher<T>, Subscriber<io.netty.buffer.ByteBufHolder>

Direct Known Subclasses:

FormDataHttpContentProcessor, JsonContentProcessor

@Internal
public abstract class AbstractHttpContentProcessor<T>
extends SingleSubscriberProcessor<io.netty.buffer.ByteBufHolder,T>
implements HttpContentProcessor<T>

Abtract implementation of the HttpContentProcessor interface that deals with limiting file upload sizes.

Since:

1.0

Author:

Graeme Rocher

Field Summary

Fields

Modifier and Type	Field and Description
protected long	advertisedLength
protected HttpServerConfiguration	configuration
protected NettyHttpRequest<?>	nettyHttpRequest
protected AtomicLong	receivedLength
protected long	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
AbstractHttpContentProcessor(NettyHttpRequest<?> nettyHttpRequest, HttpServerConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
protected void	doOnNext(io.netty.buffer.ByteBufHolder message) Implement Subscriber.onNext(Object).
protected void	doSubscribe(Subscriber<? super T> subscriber) Override to implement Publisher.subscribe(Subscriber).
protected void	fireExceedsLength(long receivedLength, long expected)
protected abstract void	onData(io.netty.buffer.ByteBufHolder message) Called after verifying the data of the message.

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

currentSubscriber, doAfterComplete, doAfterOnError, doAfterOnSubscribe, doOnComplete, doOnError, doOnSubscribe, 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

Field Detail

nettyHttpRequest

protected final NettyHttpRequest<?> nettyHttpRequest

advertisedLength

protected final long advertisedLength

requestMaxSize

protected final long requestMaxSize

receivedLength

protected final AtomicLong receivedLength

configuration

protected final HttpServerConfiguration configuration

Constructor Detail

AbstractHttpContentProcessor

public AbstractHttpContentProcessor(NettyHttpRequest<?> nettyHttpRequest,
                                    HttpServerConfiguration configuration)

Parameters:

nettyHttpRequest - The NettyHttpRequest

configuration - The HttpServerConfiguration

Method Detail

onData

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

Called after verifying the data of the message.

Parameters:

message - The message

doSubscribe

protected final void doSubscribe(Subscriber<? super T> subscriber)

Description copied from class: SingleSubscriberProcessor

Override to implement Publisher.subscribe(Subscriber).

Specified by:

doSubscribe in class SingleSubscriberProcessor<io.netty.buffer.ByteBufHolder,T>

Parameters:

subscriber - The subscriber

See Also:

Publisher.subscribe(Subscriber)

doOnNext

protected final void doOnNext(io.netty.buffer.ByteBufHolder message)

Description copied from class: CompletionAwareSubscriber

Implement Subscriber.onNext(Object).

Specified by:

doOnNext in class CompletionAwareSubscriber<io.netty.buffer.ByteBufHolder>

Parameters:

message - The message

fireExceedsLength

protected void fireExceedsLength(long receivedLength,
                                 long expected)

Parameters:

receivedLength - The length of the content received

expected - The expected length of the content