Further cleanup

_misc/_ensure_annotations.py

@@ -79,6 +79,8 @@ def version_specific_annotation_interactions(obj: Any):
 
     failures: list[tuple[str, Exception]] = []
 
+    print("Checking annotations for runtime validity", flush=True)  # noqa: T201
+
     for mod_info in pkgutil.iter_modules(async_utils.__spec__.submodule_search_locations):
         mod = importlib.import_module(f"async_utils.{mod_info.name}")
         for name in getattr(mod, "__all__", ()):

_misc/_queue_testing.py

@@ -25,8 +25,8 @@
 from contextlib import contextmanager
 from typing import Any
 
-from src.async_utils._qs import Queue  # noqa: PLC2701
-from src.async_utils.bg_loop import threaded_loop
+from async_utils.bg_loop import threaded_loop
+from async_utils.dual_color import Queue
 
 log = logging.getLogger()
 

src/async_utils/_qs.py

@@ -40,7 +40,7 @@ class AsyncEvent:
 
     def __init__(self, /) -> None:
         self._loop = asyncio.get_running_loop()
-        self._future = None
+        self._future: asyncio.Future[bool] | None = None
         self._unset = [True]
         self._cancelled = False
 
@@ -80,16 +80,14 @@ def __await__(self, /) -> Generator[t.Any, t.Any, bool]:
             self._future = self._loop.create_future()
 
             try:
-                yield from self._future.__await__()
+                return (yield from self._future.__await__())
             except BaseException:
                 self.cancel()
                 raise
             finally:
                 self._future = None
-        else:
-            yield from asyncio.sleep(0).__await__()
 
-        return True
+        return (yield from asyncio.sleep(0, True).__await__())
 
     def _set_state(self, /) -> None:
         if (future := self._future) is not None: