org.thales.punch.punchlang.util

Class MultilineCodec

java.lang.Object

org.thales.punch.punchlang.util.MultilineCodec

All Implemented Interfaces:

ICodec<String>

public class MultilineCodec
extends Object
implements ICodec<String>

Read multiline inputs based on a regex pattern. The regexp pattern is tested against each line.

Constructor Summary

Constructors

Constructor and Description
MultilineCodec(int capacity, String pattern, String delimiter, Long timeout, ECodec codec) Constructor

Method Summary

Modifier and Type	Method and Description
void	append(char[] array, int len) Append a char array at the end of the codec.
void	append(String s) Add some data to the decoder
void	flush() flush buffer
List<String>	getNextItems() Return the next complete json elements, if any.
ECodec	getType()
void	tick() Tick method, to flush data if some are present in buffer after timeout.

Methods inherited from class java.lang.Object

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

Constructor Detail

MultilineCodec

public MultilineCodec(int capacity,
                      String pattern,
                      String delimiter,
                      Long timeout,
                      ECodec codec)

Constructor

Parameters:

capacity - the buffer capacity

pattern - pattern

delimiter - delimiter

timeout - timeout

codec - type of the codec, regex or startwith, it change the pattern type

Method Detail

tick

public void tick()

Tick method, to flush data if some are present in buffer after timeout.

Specified by:

tick in interface ICodec<String>

getNextItems

public List<String> getNextItems()

Return the next complete json elements, if any.

Specified by:

getNextItems in interface ICodec<String>

Returns:

the next json items, an empty list if none are available yet

append

public void append(String s)

Add some data to the decoder

Specified by:

append in interface ICodec<String>

Parameters:

s - string

append

public void append(char[] array,
                   int len)

Description copied from interface: ICodec

Append a char array at the end of the codec.

Specified by:

append in interface ICodec<String>

Parameters:

array - the holding buffer

len - the number of read bytes

flush

public void flush()

Description copied from interface: ICodec

flush buffer

Specified by:

flush in interface ICodec<String>

getType

public ECodec getType()

Specified by:

getType in interface ICodec<String>

Returns:

this codec type