tspy.data_structures.stream_multi_time_series.MultiObservationStream module¶
-
class
tspy.data_structures.stream_multi_time_series.MultiObservationStream.MultiObservationStream(tsc, j_multi_observation_stream)¶ Bases:
objectA queue of observations that can be accessed in a streaming manner. An observation will have all values from all series associated with a time-tick as long as a value exists from that series.
Methods
peek()Peek with non-blocking for the most recent observation.
poll([polling_interval])Poll with blocking for the most recent observation and remove that observation from the queue.
-
peek()¶ Peek with non-blocking for the most recent observation. If no observation exists, return None.
- Returns
Observationthe next observation
-
poll(polling_interval=1000)¶ Poll with blocking for the most recent observation and remove that observation from the queue. If no observation exists, poll will be called every polling_interval milliseconds.
- Parameters
- polling_intervalint, optional
how often to check for a new Observation til one is returned (default is 1000)
- Returns
Observationthe next observation
-