reactor.netty

public Interface NettyInbound

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

An inbound-traffic API delegating to an underlying Channel.

Method Summary

Modifier and Type	Method and Description
public ByteBufFlux	Returns: a new `ByteBufFlux` 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 ByteBufFlux receive() A `Flux` extension that allows for extra decoding operators. Returns:ByteBufFlux a new `ByteBufFlux`

public ByteBufFlux 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