Drop 3.8, add backpressure, update old Queue usage

Author: A5rocks

.github/workflows/ci.yml

@@ -12,7 +12,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        python: ["3.8", "3.9", "3.10", "3.11", "3.12", "3.13", "pypy-3.10"]
+        python: ["3.9", "3.10", "3.11", "3.12", "3.13", "pypy-3.10"]
         platform: ["windows", "ubuntu", "macos"]
 
     steps:

noxfile.py

@@ -31,8 +31,7 @@ def test_oldest(session):
         "3.12": "trio>=0.23.0",
         "3.11": "trio>=0.21.0",
         "3.10": "trio>=0.20.0",
-        "3.9": "trio>=0.19.0",
-        "3.8": "trio",
+        "3.9": "trio",
     }
 
     session.install(".", possible_trio[pyver], "--resolution=lowest-direct")

pyproject.toml

@@ -9,8 +9,8 @@ name = "trio-monitor"
 description = "A monitor utility for Trio"
 readme = "README.rst"
 license = "MIT OR Apache-2.0"
-dependencies = ["trio>=0.15.0"]
-requires-python = ">=3.8"
+dependencies = ["trio>=0.19.0"]
+requires-python = ">=3.9"
 authors = [
 	{ name = "Lura Skye", email = "[email protected]" }
 ]

src/trio_monitor/monitor.py

@@ -54,7 +54,7 @@ def __init__(self):
         self._is_monitoring = False
         # semi-arbitrary size, because otherwise we'll be dropping events
         # no clue how to make this better, alas.
-        self._rx, self._tx = open_memory_channel(math.inf)
+        self._rx, self._tx = open_memory_channel(100)
 
     @staticmethod
     def get_root_task() -> Task:
@@ -121,7 +121,7 @@ def _add_to_monitoring_queue(self, item):
                         return
 
         try:
-            self._monitoring_queue.put_nowait(item)
+            self._tx.send_nowait(item)
         except WouldBlock:
             return
 
@@ -191,7 +191,8 @@ async def main_loop(self, stream):
     async def do_monitor(self, stream):
         """Livefeeds information about the running program."""
         prefix = "[FEED] "
-        async for item in self._monitoring_queue:
+        while True:
+            item = await self._rx.receive()
             key = item[0]
 
             if key == "task_spawned":