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(LongConsumer deserializeTmConsumer)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

BarrageStreamReader

public BarrageStreamReader(LongConsumer deserializeTmConsumer)

Method Details

safelyParseFrom

public BarrageMessage safelyParseFrom(StreamReaderOptions options,
 BitSet expectedColumns,
 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

expectedColumns - the columns expected to appear in the stream, null implies all columns

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