(self, fd)
| 291 | return handle |
| 292 | |
| 293 | def _remove_reader(self, fd): |
| 294 | if self.is_closed(): |
| 295 | return False |
| 296 | key = self._selector.get_map().get(fd) |
| 297 | if key is None: |
| 298 | return False |
| 299 | mask, (reader, writer) = key.events, key.data |
| 300 | mask &= ~selectors.EVENT_READ |
| 301 | if not mask: |
| 302 | self._selector.unregister(fd) |
| 303 | else: |
| 304 | self._selector.modify(fd, mask, (None, writer)) |
| 305 | |
| 306 | if reader is not None: |
| 307 | reader.cancel() |
| 308 | return True |
| 309 | else: |
| 310 | return False |
| 311 | |
| 312 | def _add_writer(self, fd, callback, *args): |
| 313 | self._check_closed() |
no test coverage detected