(self)
| 577 | self.assertEqual(result, [(sync_handler, 1), (async_handler, 1)]) |
| 578 | |
| 579 | def test_send_robust(self): |
| 580 | class ReceiverException(Exception): |
| 581 | pass |
| 582 | |
| 583 | receiver_exception = ReceiverException() |
| 584 | |
| 585 | async def failing_async_handler(**kwargs): |
| 586 | raise receiver_exception |
| 587 | |
| 588 | sync_handler = SyncHandler() |
| 589 | async_handler = AsyncHandler() |
| 590 | signal = dispatch.Signal() |
| 591 | signal.connect(failing_async_handler) |
| 592 | signal.connect(async_handler) |
| 593 | signal.connect(sync_handler) |
| 594 | result = signal.send_robust(self.__class__) |
| 595 | # The ordering here is different than the order that signals were |
| 596 | # connected in. |
| 597 | self.assertEqual( |
| 598 | result, |
| 599 | [ |
| 600 | (sync_handler, 1), |
| 601 | (failing_async_handler, receiver_exception), |
| 602 | (async_handler, 1), |
| 603 | ], |
| 604 | ) |
| 605 | |
| 606 | async def test_asend_robust(self): |
| 607 | class ReceiverException(Exception): |
nothing calls this directly
no test coverage detected