(self, fileobj)
| 533 | return key |
| 534 | |
| 535 | def unregister(self, fileobj): |
| 536 | key = super().unregister(fileobj) |
| 537 | if key.events & EVENT_READ: |
| 538 | kev = select.kevent(key.fd, select.KQ_FILTER_READ, |
| 539 | select.KQ_EV_DELETE) |
| 540 | self._max_events -= 1 |
| 541 | try: |
| 542 | self._selector.control([kev], 0, 0) |
| 543 | except OSError: |
| 544 | # This can happen if the FD was closed since it |
| 545 | # was registered. |
| 546 | pass |
| 547 | if key.events & EVENT_WRITE: |
| 548 | kev = select.kevent(key.fd, select.KQ_FILTER_WRITE, |
| 549 | select.KQ_EV_DELETE) |
| 550 | self._max_events -= 1 |
| 551 | try: |
| 552 | self._selector.control([kev], 0, 0) |
| 553 | except OSError: |
| 554 | # See comment above. |
| 555 | pass |
| 556 | return key |
| 557 | |
| 558 | def select(self, timeout=None): |
| 559 | timeout = None if timeout is None else max(timeout, 0) |
nothing calls this directly
no test coverage detected