Package io.deephaven.extensions.barrage.util

Class BarrageMessageReaderImpl

java.lang.Object

io.deephaven.extensions.barrage.util.BarrageMessageReaderImpl

All Implemented Interfaces:

BarrageMessageReader, SafeCloseable, AutoCloseable

public class BarrageMessageReaderImpl
extends Object
implements BarrageMessageReader

Constructor Summary

Constructors

Constructor	Description
BarrageMessageReaderImpl()
BarrageMessageReaderImpl(LongConsumer deserializeTmConsumer)

Method Summary

Modifier and Type	Method	Description
void	close()
BarrageMessage	safelyParseFrom(BarrageOptions 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

BarrageMessageReaderImpl

public BarrageMessageReaderImpl()

BarrageMessageReaderImpl

public BarrageMessageReaderImpl(LongConsumer deserializeTmConsumer)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface BarrageMessageReader

Specified by:

close in interface SafeCloseable

setDeserializeTmConsumer

public void setDeserializeTmConsumer(LongConsumer deserializeTmConsumer)

safelyParseFrom

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

Description copied from interface: BarrageMessageReader

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

Specified by:

safelyParseFrom in interface BarrageMessageReader

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