(self)
| 61 | pass |
| 62 | |
| 63 | def _worker(self): |
| 64 | while self._fd is not None: |
| 65 | try: |
| 66 | s = os.read(self._fd, 0x1000) |
| 67 | except Exception: |
| 68 | break |
| 69 | if not len(s): |
| 70 | break |
| 71 | self._process_chunk(s) |
| 72 | |
| 73 | # Flush any remaining data in the incremental decoder. |
| 74 | self._process_chunk(b"", final=True) |
| 75 | |
| 76 | def _process_chunk(self, s, final=False): |
| 77 | s = self._decoder.decode(s, final=final) |
nothing calls this directly
no test coverage detected