Struct QueueScheduler 

pub struct QueueScheduler { /* private fields */ }

Queue-based scheduler for time-skipping mode.

Executes functions sequentially in FIFO order, ignoring timestamps. This is used when time skipping is enabled to process operations as quickly as possible without waiting for actual time to pass.

Implementations

impl QueueScheduler

pub fn new() -> Self

Create a new queue scheduler.

pub fn is_processing(&self) -> bool

Check if the scheduler is currently processing.

pub fn queue_len(&self) -> usize

Get the number of queued functions.

Trait Implementations

impl Default for QueueScheduler

fn default() -> Self

Returns the “default value” for a type.

impl Scheduler for QueueScheduler

fn schedule_function( &mut self, start_invocation: BoxedAsyncFn, on_error: ErrorHandler, timestamp: Option<DateTime<Utc>>, update_checkpoint: Option<CheckpointUpdateFn>, )

Schedule a function to be executed.

fn has_scheduled_function(&self) -> bool

Check if there are scheduled functions pending.

fn flush_timers(&mut self)

Flush all scheduled functions without executing them.

fn process_next(&mut self) -> Pin<Box<dyn Future<Output = bool> + Send + '_>>

Process the next scheduled function (if any).