io.micronaut.http.server.netty

Class DefaultHttpContentProcessor

java.lang.Object

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

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

io.micronaut.http.server.netty.DefaultHttpContentProcessor

All Implemented Interfaces:

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

@Internal
public class DefaultHttpContentProcessor
extends SingleThreadedBufferingProcessor<io.netty.buffer.ByteBufHolder,io.netty.buffer.ByteBufHolder>
implements HttpContentProcessor<io.netty.buffer.ByteBufHolder>

This class will handle subscribing to a stream of HttpContent.

Since:

1.0

Author:

Graeme Rocher

Nested Class Summary

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

SingleThreadedBufferingSubscriber.BackPressureState, SingleThreadedBufferingSubscriber.DownstreamSubscription

Field Summary

Fields

Modifier and Type	Field and Description
protected long	advertisedLength
protected HttpServerConfiguration	configuration
protected io.netty.channel.ChannelHandlerContext	ctx
protected NettyHttpRequest	nettyHttpRequest
protected java.util.concurrent.atomic.AtomicLong	receivedLength
protected long	requestMaxSize
protected StreamedHttpMessage	streamedHttpMessage

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

upstreamBuffer, upstreamDemand, upstreamState, upstreamSubscription

Constructor Summary

Constructors

Constructor and Description
DefaultHttpContentProcessor(NettyHttpRequest<?> nettyHttpRequest, HttpServerConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
protected void	onUpstreamMessage(io.netty.buffer.ByteBufHolder message) Called when an message is received from the upstream Subscriber.
void	subscribe(org.reactivestreams.Subscriber<? super io.netty.buffer.ByteBufHolder> downstreamSubscriber)

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

currentDownstreamSubscriber, doOnComplete, doOnError, doOnNext, 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

Field Detail

nettyHttpRequest

protected final NettyHttpRequest nettyHttpRequest

ctx

protected final io.netty.channel.ChannelHandlerContext ctx

configuration

protected final HttpServerConfiguration configuration

advertisedLength

protected final long advertisedLength

requestMaxSize

protected final long requestMaxSize

streamedHttpMessage

protected final StreamedHttpMessage streamedHttpMessage

receivedLength

protected final java.util.concurrent.atomic.AtomicLong receivedLength

Constructor Detail

DefaultHttpContentProcessor

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

Parameters:

nettyHttpRequest - The NettyHttpRequest

configuration - The HttpServerConfiguration

Method Detail

subscribe

public final void subscribe(org.reactivestreams.Subscriber<? super io.netty.buffer.ByteBufHolder> downstreamSubscriber)

Specified by:

subscribe in interface org.reactivestreams.Publisher<io.netty.buffer.ByteBufHolder>

Overrides:

subscribe in class SingleThreadedBufferingProcessor<io.netty.buffer.ByteBufHolder,io.netty.buffer.ByteBufHolder>

onUpstreamMessage

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

Description copied from class: SingleThreadedBufferingProcessor

Called when an message is received from the upstream Subscriber.

Specified by:

onUpstreamMessage in class SingleThreadedBufferingProcessor<io.netty.buffer.ByteBufHolder,io.netty.buffer.ByteBufHolder>

Parameters:

message - The message