Package io.micronaut.http.netty.body

Class StreamingNettyByteBody.SharedBuffer

java.lang.Object

io.micronaut.http.body.stream.BaseSharedBuffer

io.micronaut.http.netty.body.StreamingNettyByteBody.SharedBuffer

All Implemented Interfaces:

BufferConsumer

Enclosing class:

StreamingNettyByteBody

@Internal
public static final class StreamingNettyByteBody.SharedBuffer
extends BaseSharedBuffer

This class buffers input data and distributes it to multiple StreamingNettyByteBody instances.

Thread safety: The BufferConsumer methods must only be called from one thread, the eventLoop thread. The other methods (subscribe, reserve) can be called from any thread.

Nested Class Summary

Nested classes/interfaces inherited from class io.micronaut.http.body.stream.BaseSharedBuffer

BaseSharedBuffer.AsFlux, BaseSharedBuffer.IncorrectContentLengthException

Nested classes/interfaces inherited from interface io.micronaut.http.body.stream.BufferConsumer

BufferConsumer.Upstream

Constructor Summary

Constructors

Constructor	Description
SharedBuffer(io.netty.channel.EventLoop loop, NettyByteBodyFactory byteBodyFactory, BodySizeLimits limits, BufferConsumer.Upstream rootUpstream)

Method Summary

Modifier and Type	Method	Description
void	add(ReadBuffer rb)	Add a given buffer to this BaseSharedBuffer. Not thread safe, caller must handle concurrency.
protected void	afterSubscribe(boolean last)	Called after a subscribe operation.
io.netty.channel.EventLoop	eventLoop()
protected void	reserve0()	Reserve a spot for a future subscribe operation. Not thread safe, caller must handle concurrency.
void	setExpectedLengthFrom(io.netty.handler.codec.http.HttpHeaders headers)

Methods inherited from class io.micronaut.http.body.stream.BaseSharedBuffer

complete, error, getExpectedLength, getLimits, getRootUpstream, logClaim, setExpectedLength, setExpectedLengthFrom, subscribe0, subscribeFull0

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.micronaut.http.body.stream.BufferConsumer

discard

Constructor Details

SharedBuffer

public SharedBuffer(io.netty.channel.EventLoop loop,
 NettyByteBodyFactory byteBodyFactory,
 BodySizeLimits limits,
 BufferConsumer.Upstream rootUpstream)

Method Details

eventLoop

public io.netty.channel.EventLoop eventLoop()

setExpectedLengthFrom

public void setExpectedLengthFrom(io.netty.handler.codec.http.HttpHeaders headers)

reserve0

protected void reserve0()

Description copied from class: BaseSharedBuffer

Reserve a spot for a future subscribe operation.
Not thread safe, caller must handle concurrency.

Overrides:

reserve0 in class BaseSharedBuffer

afterSubscribe

protected void afterSubscribe(boolean last)

Description copied from class: BaseSharedBuffer

Called after a subscribe operation. Used for leak detection.

Overrides:

afterSubscribe in class BaseSharedBuffer

Parameters:

last - true iff this was the last reservation

add

public void add(ReadBuffer rb)

Description copied from class: BaseSharedBuffer

Add a given buffer to this BaseSharedBuffer.
Not thread safe, caller must handle concurrency.

Specified by:

add in interface BufferConsumer

Overrides:

add in class BaseSharedBuffer

Parameters:

rb - The buffer