private static class Reactor2StompCodec.DecodingFunction
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private StompDecoder |
decoder |
private <any> |
messageConsumer |
Constructor and Description |
---|
DecodingFunction(StompDecoder decoder,
<any> next) |
Modifier and Type | Method and Description |
---|---|
Message<byte[]> |
apply(Buffer buffer) |
private final StompDecoder decoder
private final <any> messageConsumer
public DecodingFunction(StompDecoder decoder, <any> next)
public Message<byte[]> apply(Buffer buffer)