Add support for using QEventLoop inside of QThread

Author: kormax

qasync/__init__.py

@@ -100,6 +100,9 @@
 from ._common import with_logger  # noqa
 
 
+_AllEvents = QtCore.QEventLoop.ProcessEventsFlags(0x00)
+
+
 @with_logger
 class _QThreadWorker(QtCore.QThread):
     """
@@ -234,7 +237,7 @@ def __exit__(self, *args):
 
 def _format_handle(handle: asyncio.Handle):
     cb = getattr(handle, "_callback", None)
-    if isinstance(getattr(cb, '__self__', None), asyncio.tasks.Task):
+    if isinstance(getattr(cb, "__self__", None), asyncio.tasks.Task):
         return repr(cb.__self__)
     return str(handle)
 
@@ -292,7 +295,11 @@ def timerEvent(self, event):  # noqa: N802
                             handle._run()
                             dt = time.time() - t0
                             if dt >= loop.slow_callback_duration:
-                                self._logger.warning('Executing %s took %.3f seconds', _format_handle(handle), dt)
+                                self._logger.warning(
+                                    "Executing %s took %.3f seconds",
+                                    _format_handle(handle),
+                                    dt,
+                                )
                         finally:
                             loop._current_handle = None
                     else:
@@ -338,7 +345,7 @@ class _QEventLoop:
     ...     await asyncio.sleep(.1)
     >>>
     >>> asyncio.run(xplusy(2, 2), loop_factory=lambda:QEventLoop(app))
-    
+
     If the event loop shall be used with an existing and already running QApplication
     it must be specified in the constructor via already_running=True
     In this case the user is responsible for loop cleanup with stop() and close()
@@ -420,7 +427,9 @@ def stop(*args):
             self.run_forever()
         finally:
             future.remove_done_callback(stop)
-        self.__app.processEvents()  # run loop one last time to process all the events
+        self.__app.eventDispatcher().processEvents(
+            _AllEvents
+        )  # run loop one last time to process all the events
         if not future.done():
             raise RuntimeError("Event loop stopped before Future completed.")