ezmsg.baseproc.util.asio

Functions

run_coroutine_sync(coroutine, timeout=30)

Executes an asyncio coroutine synchronously, with enhanced error handling.

Parameters:

• coroutine (Coroutine[Any, Any, TypeVar(T)]) – The asyncio coroutine to execute

• timeout (float) – Maximum time in seconds to wait for coroutine completion (default: 30)

Return type:

TypeVar(T)

Returns:

The result of the coroutine execution

Raises:

• CoroutineExecutionError – If execution fails due to threading or event loop issues

• TimeoutError – If execution exceeds the timeout period

• Exception – Any exception raised by the coroutine

Classes

class SyncToAsyncGeneratorWrapper(gen)

Bases: object

A wrapper for synchronous generators to be used in an async context.

__init__(gen)

async asend(value)

async aclose()

Exceptions

exception CoroutineExecutionError

Bases: Exception

Custom exception for coroutine execution failures

exception CoroutineExecutionError

Bases: Exception

Custom exception for coroutine execution failures

run_coroutine_sync(coroutine, timeout=30)

Executes an asyncio coroutine synchronously, with enhanced error handling.

Parameters:

• coroutine (Coroutine[Any, Any, TypeVar(T)]) – The asyncio coroutine to execute

• timeout (float) – Maximum time in seconds to wait for coroutine completion (default: 30)

Return type:

TypeVar(T)

Returns:

The result of the coroutine execution

Raises:

• CoroutineExecutionError – If execution fails due to threading or event loop issues

• TimeoutError – If execution exceeds the timeout period

• Exception – Any exception raised by the coroutine

class SyncToAsyncGeneratorWrapper(gen)

Bases: object

A wrapper for synchronous generators to be used in an async context.

__init__(gen)

async asend(value)

async aclose()