IN
- The type produced by decodingOUT
- The type consumed by encodingpublic abstract class BufferCodec<IN,OUT> extends Codec<Buffer,IN,OUT>
DEFAULT_DELIMITER, delimiter
Modifier | Constructor and Description |
---|---|
protected |
BufferCodec()
Create a new Codec set with a \0 delimiter to finish any Buffer encoded value or scan for delimited decoded
Buffers.
|
protected |
BufferCodec(Byte delimiter)
A delimiter can be used to trail any decoded buffer or to finalize encoding from any incoming value
|
Modifier and Type | Method and Description |
---|---|
org.reactivestreams.Publisher<IN> |
decode(org.reactivestreams.Publisher<? extends Buffer> publisherToDecode)
Provide the caller with a decoder to turn a source object into an instance of the input
type.
|
org.reactivestreams.Publisher<Buffer> |
encode(org.reactivestreams.Publisher<? extends OUT> publisherToEncode)
Provide the caller with an encoder to turn an output sequence into an sequence of the source
type.
|
addDelimiterIfAny, decoder, decoder, doBufferDecode, doDelimitedBufferDecode, encoder, invokeCallbackOrReturn
protected BufferCodec()
protected BufferCodec(Byte delimiter)
delimiter
- delimiter can be left undefined (null) to bypass appending at encode time and scanning at decode
time.public org.reactivestreams.Publisher<IN> decode(org.reactivestreams.Publisher<? extends Buffer> publisherToDecode)
Codec
Copyright © 2017. All rights reserved.