Struct DeferredScheduler 

pub struct DeferredScheduler { /* private fields */ }

A ScheduleFlush that buffers callbacks and drains them when drain is called.

This is the recommended scheduler for CLI / native applications. Call drain in your main loop to process pending signal notifications and timer expirations.

Example

use auralis_task::scheduler::DeferredScheduler;
use auralis_task::init_flush_scheduler;

let sched = DeferredScheduler::new();
init_flush_scheduler(sched.clone());

// In your main loop:
loop {
    // ... application logic ...
    sched.drain();
}

Implementations

impl DeferredScheduler

pub fn new() -> Rc<Self>

Create a new deferred scheduler.

pub fn drain(&self)

Drain all pending flush callbacks.

Call this periodically (e.g. once per frame / loop iteration) to process deferred signal notifications, timer expirations, and task polls.

pub fn pending_count(&self) -> usize

Return the number of pending callbacks.

Trait Implementations

impl Default for DeferredScheduler

fn default() -> Self

Returns the “default value” for a type.

impl ScheduleFlush for DeferredScheduler

fn schedule(&self, callback: Box<dyn FnOnce()>)

Request that callback runs at the next microtask boundary.