as-async

Small python library to unblock sync functions and generators

Installation

    pip install as-async

Examples

basic usage

   import time
   import asyncio
   from concurrent.futures import ThreadPoolExecutor

   from as_async import as_async

   @as_async()
   def long_running_function():
       time.sleep(5)
       return "Finished"

   async def main():
       result = await long_running_function()
       print(result)

   asyncio.run(main())

specify loop and or executor

    import time
    import asyncio
    from concurrent.futures import ThreadPoolExecutor

    from as_async import as_async_generator

    @as_async_generator(loop=asyncio.get_event_loop(), executor=ThreadPoolExecutor(max_workers=5))
    def long_running_generator():
        for i in range(5):
            time.sleep(1)  # Simulate a long-running operation
            yield i

    async def main():
        async for value in long_running_generator():
            print(value)

    asyncio.run(main())

equivalents to the above without the decorator also exists

   import time
   import asyncio
   from concurrent.futures import ThreadPoolExecutor

   def long_running_function():
       time.sleep(5)
       return "Finished"


   async def main():
       async_func = to_async(long_running_function)
       result = await async_func()
       print(result)

   asyncio.run(main())

License

This project is licensed under the MIT License - see the LICENSE file for details