Package io.micronaut.http.netty.body

Class NettyByteBodyFactory

java.lang.Object

io.micronaut.http.body.ByteBodyFactory

io.micronaut.http.netty.body.NettyByteBodyFactory

@Internal
public final class NettyByteBodyFactory
extends ByteBodyFactory

ByteBodyFactory implementation with netty-optimized bodies.

Since:

4.8.0

Author:

Jonas Konrad

Nested Class Summary

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

ByteBodyFactory.StreamingBody

Constructor Summary

Constructors

Constructor	Description
NettyByteBodyFactory(@NonNull io.netty.channel.Channel channel)

Method Summary

Modifier and Type	Method	Description
CloseableAvailableByteBody	adapt(io.netty.buffer.ByteBuf byteBuf)
CloseableByteBody	adapt(Publisher<io.netty.buffer.ByteBuf> publisher, @Nullable io.netty.handler.codec.http.HttpHeaders headersForLength, @Nullable Runnable onDiscard)
CloseableByteBody	adaptNetty(Publisher<io.netty.buffer.ByteBuf> publisher)
protected AbstractBodyAdapter	createBodyAdapter(Publisher<ReadBuffer> publisher, Runnable onDiscard)	Create a new body adapter for transforming a publisher into a ByteBody.
CloseableByteBody	createChecked(@NonNull BodySizeLimits bodySizeLimits, @NonNull io.netty.buffer.ByteBuf buf)
ByteBodyFactory.StreamingBody	createStreamingBody(BodySizeLimits limits, BufferConsumer.Upstream upstream)	Create a new streaming body to push data into.
StreamingNettyByteBody.SharedBuffer	createStreamingBuffer(BodySizeLimits limits, BufferConsumer.Upstream rootUpstream)
static CloseableAvailableByteBody	empty()
@NonNull NettyReadBufferFactory	readBufferFactory()	Get the underlying ReadBufferFactory.
static io.netty.buffer.ByteBuf	toByteBuf(AvailableByteBody body)
static reactor.core.publisher.Flux<io.netty.buffer.ByteBuf>	toByteBufs(ByteBody body)
StreamingNettyByteBody	toStreaming(ByteBody body)	Convert a ByteBody into a BaseStreamingByteBody with the same content.

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

adapt, adapt, adapt, adapt, adapt, adapt, buffer, byteBufferFactory, copyOf, copyOf, createDefault, createEmpty

Methods inherited from class java.lang.Object

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

Constructor Details

NettyByteBodyFactory

public NettyByteBodyFactory(@NonNull
 @NonNull io.netty.channel.Channel channel)

Method Details

readBufferFactory

@NonNull
public @NonNull NettyReadBufferFactory readBufferFactory()

Description copied from class: ByteBodyFactory

Get the underlying ReadBufferFactory.

Overrides:

readBufferFactory in class ByteBodyFactory

Returns:

The factory

createStreamingBody

public ByteBodyFactory.StreamingBody createStreamingBody(BodySizeLimits limits,
 BufferConsumer.Upstream upstream)

Description copied from class: ByteBodyFactory

Create a new streaming body to push data into. Internal API.

Overrides:

createStreamingBody in class ByteBodyFactory

Parameters:

limits - The input limits

upstream - The upstream for backpressure

Returns:

The streaming body tuple

createBodyAdapter

protected AbstractBodyAdapter createBodyAdapter(Publisher<ReadBuffer> publisher,
 Runnable onDiscard)

Description copied from class: ByteBodyFactory

Create a new body adapter for transforming a publisher into a ByteBody. Internal API.

Overrides:

createBodyAdapter in class ByteBodyFactory

Parameters:

publisher - The publisher to transform

onDiscard - Optional runnable to run on BufferConsumer.Upstream.allowDiscard()

Returns:

The adapter

adapt

public CloseableAvailableByteBody adapt(io.netty.buffer.ByteBuf byteBuf)

createChecked

public CloseableByteBody createChecked(@NonNull
 @NonNull BodySizeLimits bodySizeLimits,
 @NonNull
 @NonNull io.netty.buffer.ByteBuf buf)

adaptNetty

public CloseableByteBody adaptNetty(Publisher<io.netty.buffer.ByteBuf> publisher)

adapt

public CloseableByteBody adapt(Publisher<io.netty.buffer.ByteBuf> publisher,
 @Nullable
 @Nullable io.netty.handler.codec.http.HttpHeaders headersForLength,
 @Nullable
 @Nullable Runnable onDiscard)

empty

public static CloseableAvailableByteBody empty()

toByteBuf

public static io.netty.buffer.ByteBuf toByteBuf(AvailableByteBody body)

toByteBufs

public static reactor.core.publisher.Flux<io.netty.buffer.ByteBuf> toByteBufs(ByteBody body)

createStreamingBuffer

public StreamingNettyByteBody.SharedBuffer createStreamingBuffer(BodySizeLimits limits,
 BufferConsumer.Upstream rootUpstream)

toStreaming

public StreamingNettyByteBody toStreaming(ByteBody body)

Description copied from class: ByteBodyFactory

Convert a ByteBody into a BaseStreamingByteBody with the same content. Internal API.

Overrides:

toStreaming in class ByteBodyFactory

Parameters:

body - The body to convert

Returns:

A streaming body with the same content