Add coverage test

Author: Archmonger

CHANGELOG.md

@@ -104,7 +104,7 @@ Don't forget to remove deprecated code on each major release!
 - Fixed a bug where script elements would not render to the DOM as plain text.
 - Fixed a bug where the `key` property provided within server-side ReactPy code was failing to propagate to the front-end JavaScript components.
 - Fixed a bug where `RuntimeError("Hook stack is in an invalid state")` errors could be generated when using a webserver that reuses threads.
-- Fixed a bug where events (server to client, and client to server) could be lost during rapid actions.
+- Fixed a bug where events on controlled inputs (e.g. `html.input({"onChange": ...})`) could be lost during rapid actions.
 - Allow for ReactPy and ReactJS components to be arbitrarily inserted onto the page with any possible hierarchy.
 
 ## [1.1.0] - 2024-11-24

tests/test_core/test_layout.py

@@ -122,6 +122,23 @@ async def test_thread_safe_queue_applies_backpressure():
         await queue.close()
 
 
+async def test_thread_safe_queue_close_cancels_pending_puts():
+    with patch.object(REACTPY_MAX_QUEUE_SIZE, "current", 1):
+        queue = _ThreadSafeQueue[int]()
+
+        await queue._queue.put(1)
+        queue._pending.add(2)
+        task = asyncio.create_task(queue._put_with_backpressure(2))
+        queue._put_tasks[2] = task
+
+        await asyncio.sleep(0)
+        await queue.close()
+
+        assert task.cancelled()
+        assert queue._put_tasks == {}
+        assert queue._pending == set()
+
+
 async def test_nested_component_layout():
     parent_set_state = reactpy.Ref(None)
     child_set_state = reactpy.Ref(None)