| 157 | self.asyncio_loop.close() |
| 158 | |
| 159 | def add_handler( |
| 160 | self, fd: Union[int, _Selectable], handler: Callable[..., None], events: int |
| 161 | ) -> None: |
| 162 | fd, fileobj = self.split_fd(fd) |
| 163 | if fd in self.handlers: |
| 164 | raise ValueError("fd %s added twice" % fd) |
| 165 | self.handlers[fd] = (fileobj, handler) |
| 166 | if events & IOLoop.READ: |
| 167 | self.selector_loop.add_reader(fd, self._handle_events, fd, IOLoop.READ) |
| 168 | self.readers.add(fd) |
| 169 | if events & IOLoop.WRITE: |
| 170 | self.selector_loop.add_writer(fd, self._handle_events, fd, IOLoop.WRITE) |
| 171 | self.writers.add(fd) |
| 172 | |
| 173 | def update_handler(self, fd: Union[int, _Selectable], events: int) -> None: |
| 174 | fd, fileobj = self.split_fd(fd) |