appyter.ext.asyncio package

Submodules

appyter.ext.asyncio.event_emitter module

class appyter.ext.asyncio.event_emitter.EventEmitter

Bases: object

Javascript-style event emitter

async clear()

async emit(event, **data)

async flush()

off(event, listener)

on(event)

async remove(event)

async wait(event)

appyter.ext.asyncio.event_loop module

class appyter.ext.asyncio.event_loop.EventLoopThread(loop=None)

Bases: threading.Thread

Keep the event loop running in this thread until stop is called.

run()

Method representing the thread’s activity.

You may override this method in a subclass. The standard run() method invokes the callable object passed to the object’s constructor as the target argument, if any, with sequential and keyword arguments taken from the args and kwargs arguments, respectively.

stop()

class appyter.ext.asyncio.event_loop.SharedEventLoopThreadPoolExecutor(*args, loop=None, initializer=None, **kwargs)

Bases: concurrent.futures.thread.ThreadPoolExecutor

This thread pool will initialize each thread with the same event loop.

appyter.ext.asyncio.event_loop.get_event_loop()

Get the same loop in different threads, create the loop if it doesn’t exist

appyter.ext.asyncio.event_loop.new_event_loop()

Construct a new event loop with some custom extensions:

• a dedicated thread to run the event loop

• a thread pool executor that sets the event loop in spawned threads

appyter.ext.asyncio.event_loop.with_event_loop()

appyter.ext.asyncio.helpers module

Async helpers to convert anything sync to and from anything async without deadlocks. This requires that you initialize the event loop with the appyter.ext.asyncio.event_loop methods which will run the event loop in a dedicated thread and ensure all sync methods are executed on that dedicated event loop. You only need to use ensure_async or ensure_sync these methods will deal with dispatching to the relevant handlers. It works with already-sync/async, context managers, generators, & functions of these.

async appyter.ext.asyncio.helpers.anext(generator)

async appyter.ext.asyncio.helpers.awaitable_identity(obj)

appyter.ext.asyncio.helpers.ensure_async(obj)

appyter.ext.asyncio.helpers.ensure_async_contextmanager(contextmanager)

appyter.ext.asyncio.helpers.ensure_async_func(func)

appyter.ext.asyncio.helpers.ensure_async_generator(generator)

async appyter.ext.asyncio.helpers.ensure_async_literal(obj)

appyter.ext.asyncio.helpers.ensure_async_wrapper(callable)

appyter.ext.asyncio.helpers.ensure_sync(obj)

appyter.ext.asyncio.helpers.ensure_sync_contextmanager(asynccontextmanager)

appyter.ext.asyncio.helpers.ensure_sync_coro(coro)

appyter.ext.asyncio.helpers.ensure_sync_generator(asyncgenerator)

appyter.ext.asyncio.helpers.ensure_sync_wrapper(callable)

appyter.ext.asyncio.helpers.isasynccontextmanager(obj)

appyter.ext.asyncio.helpers.iscontextmanager(obj)

appyter.ext.asyncio.subprocess module

appyter.ext.asyncio.subprocess.sh(*args, chunk_size=65536, **kwargs)

An opinionated asyncio shell that logs stderr & yields stdout, done Unlike standard create_subprocess_exec: LimitOverrunError should not be possible.

async appyter.ext.asyncio.subprocess.stream_readline_to_queue(stream, queue, chunk_size=65536)

Safely yield lines without running into buffer limit

appyter.ext.asyncio.test_helpers module

appyter.ext.asyncio.test_subprocess module

appyter.ext.asyncio.test_subprocess.test_subprocess()

appyter.ext.asyncio.try_n_times module

async appyter.ext.asyncio.try_n_times.async_try_n_times(n, coro, *args, **kwargs)

appyter.ext.asyncio.try_n_times.try_n_times(n, func, *args, **kwargs)

Module contents