reactor.netty

Interface NettyInbound

All Known Subinterfaces:

HttpServerRequest, UdpInbound, WebsocketInbound

All Known Implementing Classes:

ChannelOperations, HttpOperations

public interface NettyInbound

An inbound-traffic API delegating to an underlying Channel

Since:

0.6

Author:

Stephane Maldini

Method Summary

Modifier and Type	Method and Description
ByteBufFlux	receive() A Flux extension that allows for extra decoding operators
Flux<?>	receiveObject() a Object inbound Flux
NettyInbound	withConnection(java.util.function.Consumer<? super Connection> withConnection) Calls the passed callback with a Connection to operate on the underlying Channel state.

Method Detail

receive

ByteBufFlux receive()

A Flux extension that allows for extra decoding operators

Returns:

a new ByteBufFlux

receiveObject

Flux<?> receiveObject()

a Object inbound Flux

Returns:

a Object inbound Flux

withConnection

NettyInbound withConnection(java.util.function.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 - connection callback

Returns:

the Connection