Struct RealTime 

pub struct RealTime { /* private fields */ }

Real-time implementation that delegates to tokio.

Uses tokio::time::Instant for time tracking to ensure consistency with tokio::time::sleep(). This is important for tests using start_paused = true where tokio’s virtual time is used - using std::time::Instant would cause timing loops to run much longer than expected because wall-clock time doesn’t advance with paused tokio time.

Implementations

impl RealTime

pub fn new() -> Self

Trait Implementations

impl Clone for RealTime

fn clone(&self) -> RealTime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for RealTime

fn default() -> Self

Returns the “default value” for a type.

impl TimeSource for RealTime

fn supports_keepalive(&self) -> bool

Disable keepalive when SimulationTransportOpt is enabled.

The direct runner uses RealTime (with start_paused(true)) rather than VirtualTime for connections, so keepalive is enabled by default. But in large-scale simulations, connections never actually drop, and 15K keepalive tasks pinging every 5 seconds creates enormous scheduling overhead.

This is opt-in via SimulationTransportOpt::enable() so that tests which need keepalive behavior (e.g., connection timeout tests) can leave it off.

fn now_nanos(&self) -> u64

Returns the current time as nanoseconds since an arbitrary epoch.

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

Creates a future that completes after the given duration.

fn sleep_until( &self, deadline_nanos: u64, ) -> Pin<Box<dyn Future<Output = ()> + Send>>

Creates a future that completes when the deadline is reached or returns immediately if the deadline has passed.

fn timeout<F, T>( &self, duration: Duration, future: F, ) -> Pin<Box<dyn Future<Output = Option<T>> + Send>>

where F: Future<Output = T> + Send + 'static, T: Send + 'static,

Wraps a future with a timeout, returning None if the timeout expires.

fn now(&self) -> Duration

Returns the current time as a Duration since an arbitrary epoch.

fn connection_idle_timeout(&self) -> Duration

Returns the duration after which an idle connection should be considered dead.