(self)
| 587 | raise NotImplementedError |
| 588 | |
| 589 | def __iter__(self): |
| 590 | # avoid redundant reset when someone would call `iter()` on a new iterator |
| 591 | # do not reset if no data was consumed from the iterator - to avoid unintended |
| 592 | # buffering in the pipeline and the FW iterator |
| 593 | if self._counter != 0 and self._ever_consumed: |
| 594 | self.reset() |
| 595 | return self |
| 596 | |
| 597 | @property |
| 598 | def size(self): |