tspy.data_structures.io.PythonQueueStreamTimeSeriesReader module¶
-
class
tspy.data_structures.io.PythonQueueStreamTimeSeriesReader.PythonQueueStreamTimeSeriesReader(py_queue)¶ Bases:
tspy.data_structures.io.PullStreamTimeSeriesReader.PullStreamTimeSeriesReaderPython Queue-based StreamTimeSeriesReader
Methods
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
Observationa single observation or None if parsing has failed
-
poll()¶ poll for the latest list of messages from your source
- Returns
- list
a list of messages
-