Package reactor.netty

Interface NettyInbound

All Known Subinterfaces:
HttpServerRequest, QuicInbound, 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 Details

    • 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(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