def run_async()

in pythonflow/pfmq/_base.py [0:0]

• 5 lines of code
• 2 McCabe index (conditional complexity)

    def run_async(self):
        """
        Run the event loop in a background thread.
        """
        if not self.is_alive:
            self._thread = threading.Thread(target=self.run, daemon=True)
            self._thread.start()
        return self._thread