Add Proactor version of priority loop

src/asynkit/experimental/priority.py

@@ -1,6 +1,7 @@
 import asyncio
 import contextlib
 import random
+import sys
 import weakref
 from abc import ABC, abstractmethod
 from asyncio import Handle, Lock, Task
@@ -684,3 +685,17 @@ def __init__(self, arg: Any = None) -> None:
         super().__init__(arg)
         self.init()
         self._ready = self.ready_queue
+
+
+DefaultPriorityEventLoop = PrioritySelectorEventLoop
+
+if hasattr(asyncio, "ProactorEventLoop"):  # pragma: no coverage
+
+    class PriorityProactorEventLoop(asyncio.ProactorEventLoop, PrioritySchedulingMixin):
+        def __init__(self, arg: Any = None) -> None:
+            super().__init__(arg)
+            self.init()
+            self._ready = self.ready_queue
+
+    if sys.platform == "win32":  # pragma: no coverage
+        DefaultPriorityEventLoop = PriorityProactorEventLoop  # type: ignore

tests/experimental/test_priority.py

@@ -8,7 +8,7 @@
     PosPriorityQueue,
     PriorityCondition,
     PriorityLock,
-    PrioritySelectorEventLoop,
+    DefaultPriorityEventLoop,
     PriorityTask,
 )
 
@@ -621,7 +621,7 @@ def __init__(self, request):
         self.request = request
 
     def new_event_loop(self):
-        return PrioritySelectorEventLoop()
+        return DefaultPriorityEventLoop()
 
 
 class TestPriorityScheduling:
@@ -638,7 +638,7 @@ async def nothing():
 
     async def test_create_event_loop(self):
         loop = asyncio.get_running_loop()
-        assert isinstance(loop, PrioritySelectorEventLoop)
+        assert isinstance(loop, DefaultPriorityEventLoop)
         assert loop._ready is loop.ready_queue
 
     async def test_simple_task(self):