(self, chunk)
| 3217 | os.close(self.stream) |
| 3218 | |
| 3219 | def write_chunk(self, chunk): |
| 3220 | # in PY3, the chunk coming in will be bytes, so keep that in mind |
| 3221 | |
| 3222 | if not self.should_quit: |
| 3223 | self.should_quit = self.process_chunk(chunk) |
| 3224 | |
| 3225 | if self.save_data: |
| 3226 | self.buffer.append(chunk) |
| 3227 | |
| 3228 | if self.pipe_queue: |
| 3229 | self.log.debug("putting chunk onto pipe: %r", chunk[:30]) |
| 3230 | self.pipe_queue().put(chunk) |
| 3231 | |
| 3232 | def read(self): |
| 3233 | # if we're PY3, we're reading bytes, otherwise we're reading |