Package io.micronaut.http.body

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.

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

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	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 io.micronaut.http.body.stream.BaseSharedBuffer

afterSubscribe, getExpectedLength, getLimits, getRootUpstream, logClaim, reserve0, 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

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

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