Package deltix.qsrv.hf.stream

Class DXDataReader

java.lang.Object

deltix.qsrv.hf.stream.DXDataReader

All Implemented Interfaces:

deltix.util.lang.Disposable, java.io.Closeable, java.lang.AutoCloseable

public class DXDataReader
extends java.lang.Object
implements deltix.util.lang.Disposable

Constructor Summary

Constructors

Constructor	Description
DXDataReader(java.io.File file)

Method Summary

Modifier and Type	Method	Description
void	close()
java.lang.String	getBlockName()
RecordClassDescriptor[]	getBlockTypes()
long[]	getTimeRange()
boolean	nextBlock()
deltix.data.stream.ConsumableMessageSource<deltix.qsrv.hf.pub.InstrumentMessage>	readBlock()

Methods inherited from class java.lang.Object

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

Constructor Detail

DXDataReader

public DXDataReader(java.io.File file)
             throws java.io.IOException

Throws:

java.io.IOException

Method Detail

readBlock

public deltix.data.stream.ConsumableMessageSource<deltix.qsrv.hf.pub.InstrumentMessage> readBlock()
                                                                                           throws java.io.IOException

Throws:

java.io.IOException

nextBlock

public boolean nextBlock()
                  throws java.io.IOException

Throws:

java.io.IOException

getBlockTypes

public RecordClassDescriptor[] getBlockTypes()

getBlockName

public java.lang.String getBlockName()

getTimeRange

public long[] getTimeRange()

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface deltix.util.lang.Disposable