tspy.data_structures.io.PullStreamMultiTimeSeriesReader module¶
-
class
tspy.data_structures.io.PullStreamMultiTimeSeriesReader.PullStreamMultiTimeSeriesReader¶ Bases:
objectinterface to represent reading stream-multi-time-series data at motion from a data-source where data is being pulled to the reader
Methods
parse(message)parse a message
poll()poll for the latest list of messages from your source
-
abstract
parse(message)¶ parse a message
- Parameters
- messageAny
a message
- Returns
- tuple
a single tuple of (key,
Observation) or None if parsing has failed
-
abstract
poll()¶ poll for the latest list of messages from your source
- Returns
- list
a list of messages
-
abstract