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 431f2ed commit 117fe04Copy full SHA for 117fe04
src/trio/_core/_io_kqueue.py
@@ -93,7 +93,7 @@ def process_events(self, events: EventResult) -> None:
93
self._force_wakeup.drain()
94
continue
95
receiver = self._registered[key]
96
- if event.flags & select.KQ_EV_ONESHOT:
+ if event.flags & select.KQ_EV_ONESHOT: # TODO: test this branch
97
del self._registered[key]
98
if isinstance(receiver, _core.Task):
99
_core.reschedule(receiver, outcome.Value(event))
0 commit comments