Package io.micronaut.http.body.stream

Class BaseSharedBuffer.AsFlux

java.lang.Object

io.micronaut.http.body.stream.BaseSharedBuffer.AsFlux

All Implemented Interfaces:

BufferConsumer

Enclosing class:

BaseSharedBuffer

public static final class BaseSharedBuffer.AsFlux
extends Object
implements BufferConsumer

BufferConsumer that can subscribe to a BaseSharedBuffer and return the buffer as a Flux. Used to implement ByteBody.toReadBufferPublisher() and similar methods.

Nested Class Summary

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

BufferConsumer.Upstream

Constructor Summary

Constructors

Constructor	Description
AsFlux(BaseSharedBuffer sharedBuffer)

Method Summary

Modifier and Type	Method	Description
void	add(io.micronaut.core.io.buffer.ReadBuffer buf)	Send a buffer to this consumer.
reactor.core.publisher.Flux<io.micronaut.core.io.buffer.ReadBuffer>	asFlux(BufferConsumer.Upstream upstream)
void	complete()	Signal normal completion of the stream.
void	error(Throwable e)	Signal an upstream error.

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

Constructor Details

AsFlux

public AsFlux(BaseSharedBuffer sharedBuffer)

Method Details

add

public void add(io.micronaut.core.io.buffer.ReadBuffer buf)

Description copied from interface: BufferConsumer

Send a buffer to this consumer. Ownership of the buffer transfers to the consumer.

Specified by:

add in interface BufferConsumer

Parameters:

buf - The buffer

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

asFlux

public reactor.core.publisher.Flux<io.micronaut.core.io.buffer.ReadBuffer> asFlux(BufferConsumer.Upstream upstream)