Package io.micronaut.http.netty.body

Class NettyBodyAdapter

java.lang.Object

io.micronaut.http.body.AbstractBodyAdapter<io.netty.buffer.ByteBuf,StreamingNettyByteBody.SharedBuffer>

io.micronaut.http.netty.body.NettyBodyAdapter

All Implemented Interfaces:

BufferConsumer.Upstream, Subscriber<io.netty.buffer.ByteBuf>

@Internal
public final class NettyBodyAdapter
extends AbstractBodyAdapter<io.netty.buffer.ByteBuf,StreamingNettyByteBody.SharedBuffer>

Adapter from generic streaming ByteBody to StreamingNettyByteBody.

Since:

4.6.0

Author:

Jonas Konrad

Field Summary

Fields inherited from class io.micronaut.http.body.AbstractBodyAdapter

demand, sharedBuffer, subscription

Method Summary

Modifier and Type	Method	Description
static @NonNull NettyByteBody	adapt(@NonNull ByteBody body, @NonNull io.netty.channel.EventLoop eventLoop)	Transform the given body to a NettyByteBody.
static StreamingNettyByteBody	adapt(Publisher<io.netty.buffer.ByteBuf> publisher, io.netty.channel.EventLoop eventLoop)
static StreamingNettyByteBody	adapt(Publisher<io.netty.buffer.ByteBuf> publisher, io.netty.channel.EventLoop eventLoop, @Nullable io.netty.handler.codec.http.HttpHeaders headersForLength, @Nullable Runnable onDiscard)
void	onComplete()
void	onError(Throwable t)
void	onNext(io.netty.buffer.ByteBuf bytes)

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

allowDiscard, disregardBackpressure, onBytesConsumed, onSubscribe, start

Methods inherited from class java.lang.Object

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

Method Details

adapt

@NonNull
public static @NonNull NettyByteBody adapt(@NonNull
 @NonNull ByteBody body,
 @NonNull
 @NonNull io.netty.channel.EventLoop eventLoop)

Transform the given body to a NettyByteBody.

Parameters:

body - The generic body

eventLoop - The event loop for task serialization

Returns:

The adapted body

adapt

public static StreamingNettyByteBody adapt(Publisher<io.netty.buffer.ByteBuf> publisher,
 io.netty.channel.EventLoop eventLoop)

adapt

public static StreamingNettyByteBody adapt(Publisher<io.netty.buffer.ByteBuf> publisher,
 io.netty.channel.EventLoop eventLoop,
 @Nullable
 @Nullable io.netty.handler.codec.http.HttpHeaders headersForLength,
 @Nullable
 @Nullable Runnable onDiscard)

onNext

public void onNext(io.netty.buffer.ByteBuf bytes)

onError

public void onError(Throwable t)

Specified by:

onError in interface Subscriber<io.netty.buffer.ByteBuf>

Overrides:

onError in class AbstractBodyAdapter<io.netty.buffer.ByteBuf,StreamingNettyByteBody.SharedBuffer>

onComplete

public void onComplete()

Specified by:

onComplete in interface Subscriber<io.netty.buffer.ByteBuf>

Overrides:

onComplete in class AbstractBodyAdapter<io.netty.buffer.ByteBuf,StreamingNettyByteBody.SharedBuffer>