org.springframework.cloud.stream.app.gpfdist.sink

Class GpfdistCodec

java.lang.Object

reactor.io.codec.Codec<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer,reactor.io.buffer.Buffer>

org.springframework.cloud.stream.app.gpfdist.sink.GpfdistCodec

All Implemented Interfaces:

reactor.fn.Function<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer>

public class GpfdistCodec
extends reactor.io.codec.Codec<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer,reactor.io.buffer.Buffer>

Gpfdist related reactor Codec.

Author:

Janne Valkealahti

Field Summary

Fields inherited from class reactor.io.codec.Codec

DEFAULT_DELIMITER, delimiter

Constructor Summary

Constructors

Constructor and Description
GpfdistCodec()

Method Summary

Modifier and Type	Method and Description
reactor.io.buffer.Buffer	apply(reactor.io.buffer.Buffer t)
reactor.fn.Function<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer>	decoder(reactor.fn.Consumer<reactor.io.buffer.Buffer> next)

Methods inherited from class reactor.io.codec.Codec

addDelimiterIfAny, decode, decoder, doBufferDecode, doDelimitedBufferDecode, encode, encoder, invokeCallbackOrReturn

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GpfdistCodec

public GpfdistCodec()

Method Detail

apply

public reactor.io.buffer.Buffer apply(reactor.io.buffer.Buffer t)

decoder

public reactor.fn.Function<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer> decoder(reactor.fn.Consumer<reactor.io.buffer.Buffer> next)

Specified by:

decoder in class reactor.io.codec.Codec<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer,reactor.io.buffer.Buffer>