(self)
| 446 | d.reset_state() |
| 447 | |
| 448 | def __iter__(self): |
| 449 | itrs = [v[0].__iter__() for v in self.df_lists] |
| 450 | probs = np.array([v[1] for v in self.df_lists]) |
| 451 | try: |
| 452 | while True: |
| 453 | itr = self.rng.choice(itrs, p=probs) |
| 454 | yield next(itr) |
| 455 | except StopIteration: |
| 456 | return |
| 457 | |
| 458 | |
| 459 | class RandomMixData(RNGDataFlow): |