(self, msg)
| 681 | self.q.put((False, msg)) |
| 682 | |
| 683 | def on_trigger(self, msg): |
| 684 | # type: (bool) -> None |
| 685 | self.opened ^= True |
| 686 | self._trigger(msg) |
| 687 | while True: |
| 688 | try: |
| 689 | low, msg = self.q.get(block=False) |
| 690 | except Empty: |
| 691 | break |
| 692 | else: |
| 693 | if low: |
| 694 | self._send(msg) |
| 695 | else: |
| 696 | self._high_send(msg) |
| 697 | |
| 698 | |
| 699 | class TriggeredSwitch(Drain): |
nothing calls this directly
no test coverage detected