(self)
| 643 | self._inf_ds = RepeatedData(ds, -1) |
| 644 | |
| 645 | def reset_state(self): |
| 646 | self._guard = DataFlowReentrantGuard() |
| 647 | ProxyDataFlow.reset_state(self) |
| 648 | RNGDataFlow.reset_state(self) |
| 649 | self._iter_cnt = 0 |
| 650 | self._inf_iter = iter(self._inf_ds) |
| 651 | |
| 652 | def __len__(self): |
| 653 | return len(self.ds) * self.num_reuse |
nothing calls this directly
no test coverage detected