Reexport signals (#680)

Co-authored-by: Sam Bull <git@sambull.org>

.github/workflows/ci.yml

@@ -87,6 +87,8 @@ jobs:
       uses: re-actors/alls-green@release/v1
       with:
         jobs: ${{ toJSON(needs) }}
+    - name: Checkout
+      uses: actions/checkout@v4
     - name: Upload coverage
       uses: aio-libs/upload-coverage@v24.10.0
 

janus/__init__.py

@@ -7,15 +7,19 @@
 from heapq import heappop, heappush
 from queue import Empty as SyncQueueEmpty
 from queue import Full as SyncQueueFull
-from typing import Any, Callable, Deque, Generic, List, Optional, Protocol, Set, TypeVar
+from typing import Any, Callable, Generic, Optional, Protocol, TypeVar
 
 __version__ = "1.0.0"
 __all__ = (
     "Queue",
     "PriorityQueue",
     "LifoQueue",
     "SyncQueue",
+    "SyncQueueEmpty",
+    "SyncQueueFull",
     "AsyncQueue",
+    "AsyncQueueEmpty",
+    "AsyncQueueFull",
     "BaseQueue",
 )
 
@@ -103,7 +107,7 @@ def __init__(self, maxsize: int = 0) -> None:
         self._finished.set()
 
         self._closing = False
-        self._pending = set()  # type: Set[asyncio.Future[Any]]
+        self._pending: set[asyncio.Future[Any]] = set()
 
         def checked_call_soon_threadsafe(
             callback: Callable[..., None], *args: Any
@@ -169,7 +173,7 @@ def async_q(self) -> "_AsyncQueueProxy[T]":
     # These will only be called with appropriate locks held
 
     def _init(self, maxsize: int) -> None:
-        self._queue = deque()  # type: Deque[T]
+        self._queue: deque[T] = deque()
 
     def _qsize(self) -> int:
         return len(self._queue)
@@ -593,7 +597,7 @@ class PriorityQueue(Queue[T]):
     """
 
     def _init(self, maxsize: int) -> None:
-        self._heap_queue = []  # type: List[T]
+        self._heap_queue: list[T] = []
 
     def _qsize(self) -> int:
         return len(self._heap_queue)

tests/test_mixed.py

@@ -1,6 +1,5 @@
 import asyncio
 import contextlib
-import sys
 import threading
 
 import pytest