Commit 8bd75752 authored by Constantine's avatar Constantine
Browse files

Update streaming.py

Changed _start() method of Stream class so now thread can be join'ed.
parent 8e181580
......@@ -231,7 +231,8 @@ class Stream(object):
def _start(self, async):
self.running = True
if async:
Thread(target=self._run).start()
self._thread = Thread(target=self._run)
self._thread.start()
else:
self._run()
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment