public interface NettyInbound
Channel
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. |
ByteBufFlux receive()
Flux
extension that allows for extra decoding operatorsByteBufFlux
NettyInbound withConnection(java.util.function.Consumer<? super Connection> withConnection)
Connection
to operate on the
underlying Channel
state. This allows for chaining inbound API.withConnection
- connection callbackConnection