com.devexperts.qd.qtp

Class InputStreamParser

java.lang.Object

com.devexperts.qd.qtp.AbstractQTPParser

com.devexperts.qd.qtp.BinaryQTPParser

com.devexperts.qd.qtp.InputStreamParser

public class InputStreamParser
extends BinaryQTPParser

This parser reads and filters data and subscription from a specified InputStream in binary QTP format. It serves as a convenience object that combines input buffer and parser together. It can be used to read snapshots of data from a file, e.g. the one written with OutputStreamComposer. For more advanced file reading capabilities (to read event tapes) see com.devexperts.qd.qtp.file package.

See Also:

OutputStreamComposer

Nested Class Summary

Nested classes/interfaces inherited from class com.devexperts.qd.qtp.BinaryQTPParser

BinaryQTPParser.CorruptedException, BinaryQTPParser.CorruptedMessageException

Field Summary

Fields inherited from class com.devexperts.qd.qtp.BinaryQTPParser

symbolReader

Fields inherited from class com.devexperts.qd.qtp.AbstractQTPParser

eventTimeSequence, fieldReplacers, mixedSubscription, readEventTimeSequence, scheme, stats

Constructor Summary

Constructors

Constructor and Description
InputStreamParser(DataScheme scheme) Creates parser for the specified data scheme.

Method Summary

Modifier and Type	Method and Description
void	init(InputStream input) Initializes parser with a specified input stream.
void	setInput(com.devexperts.io.BufferedInput input) Changes input to parse messages from.

Methods inherited from class com.devexperts.qd.qtp.BinaryQTPParser

doAfterMessageBody, doAfterMessageType, doBeforeMessageLength, isSchemeKnown, newRecordMap, parseImpl, readRecordId, readSubscriptionTime, readSymbol, remapRecord, resetSession, resyncOnCorrupted, resyncOnParse, wrapRecordDesc

Methods inherited from class com.devexperts.qd.qtp.AbstractQTPParser

applyReadAs, getRecordBufferMode, nextRecordsMessage, parse, processPending, readAs, replaceFieldIfNeeded, setEventTimeSequence, setEventTimeSequenceIfNeeded, setFieldReplacers, setMixedSubscription, setReadEventTimeSequence, setStats

Methods inherited from class java.lang.Object

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

Constructor Detail

InputStreamParser

public InputStreamParser(DataScheme scheme)

Creates parser for the specified data scheme. You must init this parser before using it.

Method Detail

setInput

public void setInput(com.devexperts.io.BufferedInput input)

Changes input to parse messages from. This implementation throws UnsupportedOperationException.

Overrides:

setInput in class AbstractQTPParser

Parameters:

input - input to parse messages from.

init

public void init(InputStream input)

Initializes parser with a specified input stream. It resets session state from previous parsing session. Both parameters could be null to deinitialize parser and release object references.