Test wait_readable

Author: davidbrochart

.github/workflows/test.yml

@@ -12,6 +12,7 @@ jobs:
     runs-on: ${{ matrix.os }}
 
     strategy:
+      fail-fast: false
       matrix:
         os: [ubuntu-latest, windows-latest, macos-latest]
         python-version:
@@ -32,7 +33,9 @@ jobs:
         with:
           python-version: ${{ matrix.python-version }}
       - name: Install dependencies
-        run: pip install -e ".[test]"
+        run: |
+          pip install -e ".[test]"
+          pip install git+https://github.com/davidbrochart/anyio.git@show-error#egg=anyio --ignore-installed
       - name: Check with mypy and ruff
         if: ${{ (matrix.python-version == '3.13') && (matrix.os == 'ubuntu-latest') }}
         run: |
@@ -41,7 +44,7 @@ jobs:
           ruff check src
       - name: Run tests
         if: ${{ !((matrix.python-version == '3.13') && (matrix.os == 'ubuntu-latest')) }}
-        run: pytest --color=yes -v tests
+        run: pytest --color=yes -v tests -s
       - name: Run code coverage
         if: ${{ (matrix.python-version == '3.13') && (matrix.os == 'ubuntu-latest') }}
         run: |

tests/test_socket.py

@@ -1,8 +1,9 @@
 import json
+import socket
 
 import pytest
 import zmq
-from anyio import create_task_group, fail_after, move_on_after, sleep, to_thread
+from anyio import create_task_group, fail_after, move_on_after, sleep, to_thread, wait_all_tasks_blocked, wait_readable
 from anyioutils import CancelledError, Future, create_task
 from zmq_anyio import Poller, Socket
 
@@ -342,3 +343,24 @@ async def test_close(create_bound_pair):
             await tg.start(b.start)
             a.close()
             b.close()
+            await sleep(0.1)
+
+
+async def test_wait_readable():
+    with fail_after(1):
+        s1, s2 = socket.socketpair()
+        with s1, s2:
+            s1.setblocking(False)
+            s2.setblocking(False)
+            async with create_task_group() as tg:
+                tg.start_soon(wait_readable, s2)
+                await wait_all_tasks_blocked()
+                await sleep(0.1)
+                tg.cancel_scope.cancel()
+
+        s1, s2 = socket.socketpair()
+        with s1, s2:
+            s1.setblocking(False)
+            s2.setblocking(False)
+            s1.send(b"\x00")
+            await wait_readable(s2)