Remove a writer callback.
(self, fd)
| 328 | return handle |
| 329 | |
| 330 | def _remove_writer(self, fd): |
| 331 | """Remove a writer callback.""" |
| 332 | if self.is_closed(): |
| 333 | return False |
| 334 | key = self._selector.get_map().get(fd) |
| 335 | if key is None: |
| 336 | return False |
| 337 | mask, (reader, writer) = key.events, key.data |
| 338 | # Remove both writer and connector. |
| 339 | mask &= ~selectors.EVENT_WRITE |
| 340 | if not mask: |
| 341 | self._selector.unregister(fd) |
| 342 | else: |
| 343 | self._selector.modify(fd, mask, (reader, None)) |
| 344 | |
| 345 | if writer is not None: |
| 346 | writer.cancel() |
| 347 | return True |
| 348 | else: |
| 349 | return False |
| 350 | |
| 351 | def add_reader(self, fd, callback, *args): |
| 352 | """Add a reader callback.""" |
no test coverage detected