(self, fd, callback, *args, context=None)
| 313 | return False |
| 314 | |
| 315 | def _add_writer(self, fd, callback, *args, context=None): |
| 316 | self._check_closed() |
| 317 | handle = events.Handle(callback, args, self, context=context) |
| 318 | key = self._selector.get_map().get(fd) |
| 319 | if key is None: |
| 320 | self._selector.register(fd, selectors.EVENT_WRITE, |
| 321 | (None, handle)) |
| 322 | else: |
| 323 | mask, (reader, writer) = key.events, key.data |
| 324 | self._selector.modify(fd, mask | selectors.EVENT_WRITE, |
| 325 | (reader, handle)) |
| 326 | if writer is not None: |
| 327 | writer.cancel() |
| 328 | return handle |
| 329 | |
| 330 | def _remove_writer(self, fd): |
| 331 | """Remove a writer callback.""" |
no test coverage detected