Package io.micronaut.http.body

Class ConcatenatingSubscriber.ByteBufferConcatenatingSubscriber

java.lang.Object

io.micronaut.http.body.ConcatenatingSubscriber

io.micronaut.http.body.ConcatenatingSubscriber.ByteBufferConcatenatingSubscriber

All Implemented Interfaces:

BufferConsumer, BufferConsumer.Upstream, Subscriber<ByteBody>, reactor.core.CoreSubscriber<ByteBody>

Direct Known Subclasses:

ConcatenatingSubscriber.JsonByteBufferConcatenatingSubscriber

Enclosing class:

ConcatenatingSubscriber

public static class ConcatenatingSubscriber.ByteBufferConcatenatingSubscriber
extends ConcatenatingSubscriber

Concatenating implementation that writes to a ReactiveByteBufferByteBody.

Nested Class Summary

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

ConcatenatingSubscriber.ByteBufferConcatenatingSubscriber, ConcatenatingSubscriber.JsonByteBufferConcatenatingSubscriber

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

BufferConsumer.Upstream

Method Summary

Modifier and Type	Method	Description
void	add(@NonNull ByteBuffer buffer)
static CloseableByteBody	concatenate(Publisher<ByteBody> publisher)
protected BufferConsumer.Upstream	forward(ByteBody body)	Forward the given body to the shared buffer.
protected void	forwardComplete()	Forward completion to the shared buffer.
protected void	forwardError(Throwable t)	Forward an error to the shared buffer.

Methods inherited from class io.micronaut.http.body.ConcatenatingSubscriber

allowDiscard, complete, disregardBackpressure, emitFinalSeparator, emitLeadingSeparator, error, onBytesConsumed, onComplete, onError, onForward, onNext, onSubscribe, start

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

complete, discard, error

Methods inherited from interface reactor.core.CoreSubscriber

currentContext

Method Details

concatenate

public static CloseableByteBody concatenate(Publisher<ByteBody> publisher)

forward

protected BufferConsumer.Upstream forward(ByteBody body)

Description copied from class: ConcatenatingSubscriber

Forward the given body to the shared buffer.

Specified by:

forward in class ConcatenatingSubscriber

Parameters:

body - The body

Returns:

The BufferConsumer.Upstream to control component backpressure, or null if all bytes were written immediately (as is the case for an AvailableByteBody)

add

public void add(@NonNull
 @NonNull ByteBuffer buffer)

forwardComplete

protected void forwardComplete()

Description copied from class: ConcatenatingSubscriber

Forward completion to the shared buffer.

Specified by:

forwardComplete in class ConcatenatingSubscriber

forwardError

protected void forwardError(Throwable t)

Description copied from class: ConcatenatingSubscriber

Forward an error to the shared buffer.

Specified by:

forwardError in class ConcatenatingSubscriber

Parameters:

t - The error