(self, batch)
| 300 | self.send_idx += 1 |
| 301 | |
| 302 | def _process_next_batch(self, batch): |
| 303 | self.rcvd_idx += 1 |
| 304 | self._put_indices() |
| 305 | if isinstance(batch, ExceptionWrapper): |
| 306 | raise batch.exc_type(batch.exc_msg) |
| 307 | return batch |
| 308 | |
| 309 | def __getstate__(self): |
| 310 | # TODO: add limited pickling support for sharing an iterator |