Args: names: list[str] names of readers; used as schema keys readers: list[Reader] Reader instances, must have schema
(self, names, readers)
| 522 | multiple sources simultaneously. |
| 523 | """ |
| 524 | def __init__(self, names, readers): |
| 525 | """ |
| 526 | Args: |
| 527 | names: list[str] names of readers; used as schema keys |
| 528 | readers: list[Reader] Reader instances, must have schema |
| 529 | """ |
| 530 | assert len(names) == len(readers) |
| 531 | super().__init__(schema=Struct(*[ |
| 532 | (name, reader.schema()) for name, reader in zip(names, readers) |
| 533 | ])) |
| 534 | self._names = names |
| 535 | self._readers = readers |
| 536 | |
| 537 | def setup_ex(self, init_net, finish_net): |
| 538 | for reader in self._readers: |