reactor.netty5

public Interface NettyInbound

Known Direct Subinterfaces: reactor.netty5.udp.UdpInbound
Known Direct Implementers: reactor.netty5.channel.ChannelOperations
Imports: java.util.function.Consumer, io.netty5.channel.Channel, reactor.core.publisher.Flux

An inbound-traffic API delegating to an underlying Channel

Method Summary

Modifier and Type	Method and Description
public BufferFlux	Returns: a new `BufferFlux` receive() A `Flux` extension that allows for extra decoding operators
public Flux<?>	Returns: a Object inbound `Flux` receiveObject() a Object inbound `Flux`
public NettyInbound	Returns: the `Connection` withConnection(Consumer<? super Connection> connection callback withConnection) Calls the passed callback with a `Connection` to operate on the underlying `Channel` state.

receive back to summary

receive	back to summary
public BufferFlux receive() A `Flux` extension that allows for extra decoding operators Returns:BufferFlux a new `BufferFlux`

public BufferFlux receive()

A Flux extension that allows for extra decoding operators

receiveObject back to summary

receiveObject	back to summary
public Flux<?> receiveObject() a Object inbound `Flux` Returns:Flux<?> a Object inbound `Flux`

public Flux<?> receiveObject()

a Object inbound Flux

withConnection back to summary

withConnection	back to summary
public NettyInbound withConnection(Consumer<? super Connection> withConnection) Calls the passed callback with a `Connection` to operate on the underlying `Channel` state. This allows for chaining inbound API. Parameters withConnection:Consumer<? super Connection> connection callback Returns:NettyInbound the `Connection`

public NettyInbound withConnection(Consumer<? super Connection> withConnection)

Calls the passed callback with a Connection to operate on the underlying Channel state. This allows for chaining inbound API.

Parameters