()
| 126 | await loop.run_in_executor(None, send_queued_messages) |
| 127 | |
| 128 | async def async_link_loop(): |
| 129 | loop = asyncio.get_event_loop() |
| 130 | await loop.run_in_executor(None, link.loop) |
| 131 | |
| 132 | # Wrap the snakemq_link.Link loop in an asyncio task |
| 133 | await asyncio.gather(async_send_queued_messages(), async_link_loop()) |