Do not clear event in run to avoid race condition

src/AsapoWorker/streamer.py

@@ -93,7 +93,6 @@ class Streamer:
 
     def run(self):
         log.info("Start stream processing.")
-        self.stopped.clear()
         try:
             while not self.stopped.is_set():
                 success = self._process_stream()