Package io.deephaven.extensions.barrage.util

Interface StreamReader

All Known Implementing Classes:

BarrageStreamReader

public interface StreamReader

Thread safe re-usable reader that converts an InputStreams to BarrageMessages.

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.

Method Details

safelyParseFrom

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.

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