public abstract class CompressionCodec<IN,OUT> extends BufferCodec<IN,OUT>
DEFAULT_DELIMITER, delimiter
Modifier | Constructor and Description |
---|---|
protected |
CompressionCodec(Codec<Buffer,IN,OUT> delegate) |
Modifier and Type | Method and Description |
---|---|
Buffer |
apply(OUT out)
Execute the logic of the action, accepting the given parameter.
|
protected abstract InputStream |
createInputStream(InputStream parent) |
protected abstract OutputStream |
createOutputStream(OutputStream parent) |
Function<Buffer,IN> |
decoder(Consumer<IN> next)
Provide the caller with a decoder to turn a source object into an instance of the input
type.
|
decode, encode
addDelimiterIfAny, decoder, doBufferDecode, doDelimitedBufferDecode, encoder, invokeCallbackOrReturn
public Function<Buffer,IN> decoder(Consumer<IN> next)
Codec
public Buffer apply(OUT out)
Function
out
- The parameter to pass to the action.protected abstract InputStream createInputStream(InputStream parent) throws IOException
IOException
protected abstract OutputStream createOutputStream(OutputStream parent) throws IOException
IOException
Copyright © 2016. All rights reserved.