Repository URL to install this package:
|
Version:
2.0.1 ▾
|
"""Concurrency-related utility functions."""
from .bundler import AsyncBundler
from .delay import delayed
from .future import Future, FutureCancelled, FutureMap
from .race import race
from .scheduler import Job, Scheduler
from .tasks import AwaitableCancelScope, cancellable, CancellableTaskGroup
from .watchdog import Watchdog, use_watchdog
__all__ = (
"AsyncBundler",
"AwaitableCancelScope",
"cancellable",
"CancellableTaskGroup",
"delayed",
"Future",
"FutureCancelled",
"FutureMap",
"Job",
"race",
"Scheduler",
"use_watchdog",
"Watchdog",
)