itdaniher · November 30, 2017 21:17
diff --git a/async_wrapper.py b/async_wrapper.py
 import concurrent.futures

 async def async_wrapper(loop, functional, args=(None)):
    with concurrent.futures.ThreadPoolExecutor() as executor:
        return await loop.run_in_executor(executor, functional, args)
	import concurrent.futures

	async def async_wrapper(loop, functional, args=(None)):
	with concurrent.futures.ThreadPoolExecutor() as executor:
	return await loop.run_in_executor(executor, functional, args)