tspy.data_structures.io.PythonQueueStreamMultiTimeSeriesReader module¶
-
class
tspy.data_structures.io.PythonQueueStreamMultiTimeSeriesReader.PythonQueueStreamMultiTimeSeriesReader(py_queue)¶ Bases:
tspy.data_structures.io.PullStreamMultiTimeSeriesReader.PullStreamMultiTimeSeriesReaderMethods
parse(message)parse a message
poll()poll for the latest list of messages from your source
-
parse(message)¶ parse a message
- Parameters
- messageAny
a message
- Returns
- tuple
a single tuple of (key,
Observation) or None if parsing has failed
-
poll()¶ poll for the latest list of messages from your source
- Returns
- list
a list of messages
-