()
| 251 | if async_receivers: |
| 252 | |
| 253 | async def asend(): |
| 254 | async_responses = await _run_parallel( |
| 255 | *( |
| 256 | receiver(signal=self, sender=sender, **named) |
| 257 | for receiver in async_receivers |
| 258 | ) |
| 259 | ) |
| 260 | return zip(async_receivers, async_responses) |
| 261 | |
| 262 | responses.extend(async_to_sync(asend)()) |
| 263 | return responses |