(self)
| 628 | self.period2 = period2 |
| 629 | |
| 630 | def generate(self): |
| 631 | # type: () -> None |
| 632 | while self.RUN: |
| 633 | empty_gen = True |
| 634 | for m in self.msg: |
| 635 | empty_gen = False |
| 636 | self._gen_data(m) |
| 637 | time.sleep(self.period) |
| 638 | if empty_gen: |
| 639 | self.is_exhausted = True |
| 640 | self._exhaust() |
| 641 | time.sleep(self.period2) |
| 642 | |
| 643 | |
| 644 | class TermSink(Sink): |
no test coverage detected