Class ReactiveByteBufferByteBody.SharedBuffer

java.lang.Object

io.micronaut.http.body.stream.BaseSharedBuffer

io.micronaut.http.body.ReactiveByteBufferByteBody.SharedBuffer

All Implemented Interfaces:

BufferConsumer

Enclosing class:

ReactiveByteBufferByteBody

public static final class ReactiveByteBufferByteBody.SharedBuffer
extends BaseSharedBuffer
implements BufferConsumer

Simple implementation of BaseSharedBuffer that consumes ByteBuffers.
Buffering is done using a ByteArrayOutputStream. Concurrency control is done through a non-reentrant lock based on AtomicReference.

Since:

4.8.0

Author:

Jonas Konrad

Nested Class Summary

Nested classes/interfaces inherited from class BaseSharedBuffer

BaseSharedBuffer.AsFlux, BaseSharedBuffer.IncorrectContentLengthException

Nested classes/interfaces inherited from interface BufferConsumer

BufferConsumer.Upstream

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.
void	addAndComplete(ReadBuffer rb)	Add a given buffer to this BaseSharedBuffer and complete it, in one operation.
void	complete()	Implementation of BufferConsumer.complete(). Not thread safe, caller must handle concurrency.
void	error(Throwable e)	Implementation of BufferConsumer.error(Throwable). Not thread safe, caller must handle concurrency.
DelayedExecutionFlow<ReadBuffer>	subscribeFull(BufferConsumer.Upstream specificUpstream)

Methods inherited from class BaseSharedBuffer

addGuarded, addSizeLimitTrackers, afterSubscribe, getExpectedLength, getRootUpstream, logClaim, reserve0, setExpectedLength, setExpectedLengthFrom, subscribe0, subscribeFull0

Methods inherited from class Object

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

Methods inherited from interface BufferConsumer

discard

Method Details

subscribeFull

public DelayedExecutionFlow<ReadBuffer> subscribeFull(BufferConsumer.Upstream specificUpstream)

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

addAndComplete

public void addAndComplete(ReadBuffer rb)

Description copied from class: BaseSharedBuffer

Add a given buffer to this BaseSharedBuffer and complete it, in one operation. This allows subscribers that implement BufferConsumer.addAndComplete(ReadBuffer) to combine the final bytes and the completion signal into a single downstream message.
Not thread safe, caller must handle concurrency.

Specified by:

addAndComplete in interface BufferConsumer

Overrides:

addAndComplete in class BaseSharedBuffer

Parameters:

rb - The final buffer

error

public void error(Throwable e)

Description copied from class: BaseSharedBuffer

Implementation of BufferConsumer.error(Throwable).
Not thread safe, caller must handle concurrency.

Specified by:

error in interface BufferConsumer

Overrides:

error in class BaseSharedBuffer

Parameters:

e - The error

complete

public void complete()

Description copied from class: BaseSharedBuffer

Implementation of BufferConsumer.complete().
Not thread safe, caller must handle concurrency.

Specified by:

complete in interface BufferConsumer

Overrides:

complete in class BaseSharedBuffer