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.