()
| 811 | return |
| 812 | |
| 813 | def run_handlers(): |
| 814 | for handler in handlers: |
| 815 | try: |
| 816 | try: |
| 817 | handler(response) |
| 818 | except MessageHandlingError as exc: |
| 819 | if not exc.applies_to(response): |
| 820 | raise |
| 821 | log.error( |
| 822 | "Handler {0}\ncouldn't handle {1}:\n{2}", |
| 823 | util.srcnameof(handler), |
| 824 | response.describe(), |
| 825 | str(exc), |
| 826 | ) |
| 827 | except Exception: |
| 828 | log.reraise_exception( |
| 829 | "Handler {0}\ncouldn't handle {1}:", |
| 830 | util.srcnameof(handler), |
| 831 | response.describe(), |
| 832 | ) |
| 833 | |
| 834 | handlers = self._response_handlers[:] |
| 835 | self.channel._enqueue_handlers(response, run_handlers) |
nothing calls this directly
no test coverage detected