Package io.deephaven.extensions.barrage.util

Class BarrageStreamReader

java.lang.Object

io.deephaven.extensions.barrage.util.BarrageStreamReader

All Implemented Interfaces:

StreamReader

public class BarrageStreamReader
extends Object
implements StreamReader

Constructor Summary

Constructors

Constructor	Description
BarrageStreamReader()
BarrageStreamReader(LongConsumer deserializeTmConsumer)

Method Summary

Modifier and Type	Method	Description
BarrageMessage	safelyParseFrom(StreamReaderOptions options, ChunkType[] columnChunkTypes, Class<?>[] columnTypes, Class<?>[] componentTypes, InputStream stream)	Converts an InputStream to a BarrageMessage in the context of the provided parameters.
void	setDeserializeTmConsumer(LongConsumer deserializeTmConsumer)

Methods inherited from class java.lang.Object

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

Constructor Details

BarrageStreamReader

public BarrageStreamReader()

BarrageStreamReader

public BarrageStreamReader(LongConsumer deserializeTmConsumer)

Method Details

setDeserializeTmConsumer

public void setDeserializeTmConsumer(LongConsumer deserializeTmConsumer)

safelyParseFrom

public BarrageMessage safelyParseFrom(StreamReaderOptions options,
 ChunkType[] columnChunkTypes,
 Class<?>[] columnTypes,
 Class<?>[] componentTypes,
 InputStream stream)

Description copied from interface: StreamReader

Converts an InputStream to a BarrageMessage in the context of the provided parameters.

Specified by:

safelyParseFrom in interface StreamReader

Parameters:

options - the options related to parsing this message

columnChunkTypes - the types to use for each column chunk

columnTypes - the actual type for the column

componentTypes - the actual component type for the column

stream - the input stream that holds the message to be parsed

Returns:

a BarrageMessage filled out by the stream's payload