Package io.micronaut.http.server.netty.body

Class StreamingNettyByteBody.SharedBuffer

java.lang.Object

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

All Implemented Interfaces:

BufferConsumer

Enclosing class:

StreamingNettyByteBody

public static final class StreamingNettyByteBody.SharedBuffer
extends Object
implements BufferConsumer

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 eventLoopFlow thread. The other methods (subscribe, reserve) can be called from any thread.

Nested Class Summary

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

BufferConsumer.Upstream

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	add(io.netty.buffer.ByteBuf buf)	Consume a buffer.
void	complete()	Signal normal completion of the stream.
void	error(Throwable e)	Signal an upstream error.
void	setExpectedLength(long length)
void	setExpectedLengthFrom(io.netty.handler.codec.http.HttpHeaders headers)

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.server.netty.body.BufferConsumer

discard

Constructor Details

SharedBuffer

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

Method Details

setExpectedLengthFrom

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

setExpectedLength

public void setExpectedLength(long length)

add

public void add(io.netty.buffer.ByteBuf buf)

Description copied from interface: BufferConsumer

Consume a buffer. Release ownership is transferred to this consumer.

Specified by:

add in interface BufferConsumer

Parameters:

buf - The buffer to consume

complete

public void complete()

Description copied from interface: BufferConsumer

Signal normal completion of the stream.

Specified by:

complete in interface BufferConsumer

error

public void error(Throwable e)

Description copied from interface: BufferConsumer

Signal an upstream error.

Specified by:

error in interface BufferConsumer

Parameters:

e - The error