Struct Reactor 

pub struct Reactor { /* private fields */ }

Implementations

impl Reactor

pub fn new(seed: u64) -> Self

pub fn new_with_trace(seed: u64, trace_config: TraceConfig) -> Self

pub fn new_for_engine(&self) -> Self

pub fn clock_ref(&self) -> &Arc<Mutex<Clock>>

pub fn spawn_local_task( &self, fut: Pin<Box<dyn Future<Output = ()> + Send + 'static>>, ) -> TaskHandle

pub fn yield_now( &self, ) -> Pin<Box<dyn Future<Output = ()> + Send + Sync + 'static>>

pub fn sleep( &self, duration: Duration, ) -> Pin<Box<dyn Future<Output = ()> + Send + Sync + 'static>>

pub fn create_interval(&self, duration: Duration) -> Interval

pub fn run_until_idle(&self)

pub fn advance_time(&self, d: Duration)

pub fn run_to_completion(&self)

pub fn step_count(&self) -> u64

pub fn seed(&self) -> u64

pub fn virtual_elapsed(&self) -> Duration

pub fn now(&self) -> Instant

pub fn elapsed_since(&self, _start: Instant) -> u64

pub fn next_u64(&self) -> u64

pub fn decision_log(&self) -> Vec<usize>

pub fn set_replay_decisions(&self, decisions: Vec<usize>)

pub fn clear_decision_log(&self)

pub fn trace_snapshot(&self) -> TraceBuffer

Trait Implementations

impl Clone for Reactor

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl DeterministicControl for Reactor

fn spawn_local_task(&self, fut: TaskFuture) -> TaskHandle

fn run_until_idle(&self)

fn advance_time(&self, duration: Duration)

fn run_to_completion(&self)

fn step_count(&self) -> u64

fn seed(&self) -> u64

fn virtual_elapsed(&self) -> Duration

fn decision_log(&self) -> Vec<usize>

fn set_replay_decisions(&self, decisions: Vec<usize>)

fn clear_decision_log(&self)

fn trace_snapshot(&self) -> TraceBuffer

impl Runtime for Reactor

fn clock_ref(&self) -> &Arc<Mutex<Clock>>

fn yield_now(&self) -> RuntimeFuture

fn sleep(&self, duration: Duration) -> RuntimeFuture

fn create_interval(&self, duration: Duration) -> Interval

fn now(&self) -> Instant

fn elapsed_since(&self, start: Instant) -> u64

fn next_u64(&self) -> u64