|
|
@ -26,8 +26,10 @@ class EventStream:
|
|
|
|
:rtype: str
|
|
|
|
:rtype: str
|
|
|
|
"""
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
while True:
|
|
|
|
if self.queue or (len(self.queue) > 0):
|
|
|
|
if self.queue or (len(self.queue) > 0):
|
|
|
|
return self.queue.popleft()
|
|
|
|
yield self.queue.popleft()
|
|
|
|
|
|
|
|
time.sleep(0.1)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
event_stream = EventStream()
|
|
|
|
event_stream = EventStream()
|
|
|
|