Updated
On this page
AsyncioFlushScheduler: the concrete FlushScheduler implementation, using asyncio's call_later() to demand-schedule dispatch accumulator flush callbacks with a cancellable handle.
#services.src.orxtra.services._flush
#services.src.orxtra.services._flush
#AsyncioFlushScheduler
Concrete FlushScheduler using asyncio.get_running_loop().call_later().
Satisfies the FlushScheduler protocol from orxtra.protocols. Demand-driven: schedules a deferred callback after deadline seconds. Returns a handle that can be cancelled.
#schedule_flush
python
def schedule_flush(self, deadline: float, callback: Callable[[], Awaitable[None]]) -> object#cancel_flush
python
def cancel_flush(self, handle: object) -> None