@Internal public class DefaultHttpContentProcessor extends SingleThreadedBufferingProcessor<io.netty.buffer.ByteBufHolder,io.netty.buffer.ByteBufHolder> implements HttpContentProcessor<io.netty.buffer.ByteBufHolder>
HttpContent
.SingleThreadedBufferingSubscriber.BackPressureState, SingleThreadedBufferingSubscriber.DownstreamSubscription
Modifier and Type | Field and Description |
---|---|
protected long |
advertisedLength |
protected HttpServerConfiguration |
configuration |
protected io.netty.channel.ChannelHandlerContext |
ctx |
protected NettyHttpRequest |
nettyHttpRequest |
protected AtomicLong |
receivedLength |
protected long |
requestMaxSize |
protected StreamedHttpMessage |
streamedHttpMessage |
upstreamBuffer, upstreamDemand, upstreamState, upstreamSubscription
Constructor and Description |
---|
DefaultHttpContentProcessor(NettyHttpRequest<?> nettyHttpRequest,
HttpServerConfiguration configuration) |
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(Subscriber<? super io.netty.buffer.ByteBufHolder> downstreamSubscriber) |
currentDownstreamSubscriber, doOnComplete, doOnError, doOnNext, doOnSubscribe, getDownstreamSubscriber, subscribeDownstream
newDownstreamSubscription, onComplete, onError, onNext, onSubscribe, provideDownstreamSubscription
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onComplete, onError, onNext, onSubscribe
isEnabled
protected final NettyHttpRequest nettyHttpRequest
protected final io.netty.channel.ChannelHandlerContext ctx
protected final HttpServerConfiguration configuration
protected final long advertisedLength
protected final long requestMaxSize
protected final StreamedHttpMessage streamedHttpMessage
protected final AtomicLong receivedLength
public DefaultHttpContentProcessor(NettyHttpRequest<?> nettyHttpRequest, HttpServerConfiguration configuration)
nettyHttpRequest
- The NettyHttpRequest
configuration
- The HttpServerConfiguration
public final void subscribe(Subscriber<? super io.netty.buffer.ByteBufHolder> downstreamSubscriber)
subscribe
in interface Publisher<io.netty.buffer.ByteBufHolder>
subscribe
in class SingleThreadedBufferingProcessor<io.netty.buffer.ByteBufHolder,io.netty.buffer.ByteBufHolder>
protected void onUpstreamMessage(io.netty.buffer.ByteBufHolder message)
SingleThreadedBufferingProcessor
Subscriber
.onUpstreamMessage
in class SingleThreadedBufferingProcessor<io.netty.buffer.ByteBufHolder,io.netty.buffer.ByteBufHolder>
message
- The message