(receiver)
| 371 | if async_receivers: |
| 372 | |
| 373 | async def asend_and_wrap_exception(receiver): |
| 374 | try: |
| 375 | response = await receiver(signal=self, sender=sender, **named) |
| 376 | except Exception as err: |
| 377 | self._log_robust_failure(receiver, err) |
| 378 | return err |
| 379 | return response |
| 380 | |
| 381 | async def asend(): |
| 382 | async_responses = await _run_parallel( |
nothing calls this directly
no test coverage detected