aio-executor 0.1.0

A concurrent.futures.Executor implementation that runs asynchronous tasks in an asyncio event loop.

aio-executor

A concurrent.futures.Executor implementation that runs asynchronous tasks in an asyncio loop.

Example usage:

from aio_executor import AioExecutor

async def my_async_function(arg):
    # ...

with AioExecutor() as aioexec:
    # single invocation
    aioexec.submit(my_async_function, 'foo')

    # multiple concurrent invocations using "map"
    aioexec.map(my_async_function, ['foo', 'bar', 'baz'])