(self)
| 219 | self._guard = DataFlowReentrantGuard() |
| 220 | |
| 221 | def __iter__(self): |
| 222 | with self._guard: |
| 223 | for dp in self.ds: |
| 224 | shp = dp[self.idx].shape |
| 225 | holder = self.holder[shp] |
| 226 | holder.append(dp) |
| 227 | if len(holder) == self.batch_size: |
| 228 | yield BatchData.aggregate_batch(holder) |
| 229 | del holder[:] |
| 230 | |
| 231 | |
| 232 | class FixedSizeData(ProxyDataFlow): |
nothing calls this directly
no test coverage detected