Close the pipe file descriptors.
(self)
| 156 | self._queue = queue.SimpleQueue() |
| 157 | |
| 158 | def close(self): |
| 159 | """Close the pipe file descriptors.""" |
| 160 | if self._read_fd is not None: |
| 161 | try: |
| 162 | os.close(self._read_fd) |
| 163 | except OSError: |
| 164 | pass |
| 165 | if self._write_fd is not None: |
| 166 | try: |
| 167 | os.close(self._write_fd) |
| 168 | except OSError: |
| 169 | pass |
| 170 | |
| 171 | def fileno(self): |
| 172 | """Return the readable file descriptor for selector registration.""" |