We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fb83a3f commit 3b9e0d4Copy full SHA for 3b9e0d4
src/frequenz/channels/_select.py
@@ -430,6 +430,9 @@ async def select( # noqa: DOC503
430
receivers_map: dict[str, Receiver[Any]] = {str(hash(r)): r for r in receivers}
431
pending: set[asyncio.Task[bool]] = set()
432
433
+ if asyncio.get_event_loop().is_closed():
434
+ raise SelectError("Cannot select on a closed event loop")
435
+
436
try:
437
for name, recv in receivers_map.items():
438
pending.add(asyncio.create_task(recv.ready(), name=name))
0 commit comments