threading

class mersal.threading.AnyIOPeriodicTask[source]

Bases: PeriodicAsyncTask

AnyIOPeriodicTask(description: str, task: collections.abc.Callable[…, collections.abc.Awaitable[typing.Any]], period: float, logger: mersal.logging.logger.Logger)

__init__(description: str, task: Callable[[...], Awaitable[Any]], period: float, logger: Logger) None[source]
class mersal.threading.AnyIOPeriodicTaskFactory[source]

Bases: PeriodicAsyncTaskFactory

__init__(logger: Logger) None[source]
class mersal.threading.PeriodicAsyncTask[source]

Bases: Protocol

__init__(*args, **kwargs)
class mersal.threading.PeriodicAsyncTaskFactory[source]

Bases: Protocol

__init__(*args, **kwargs)