Struct tor_rtmock::MockSleepRuntime

pub struct MockSleepRuntime<R: Runtime> { /* fields omitted */ }

A wrapper Runtime that overrides the SleepProvider trait for the underlying runtime.

Implementations

impl<R: Runtime> MockSleepRuntime<R>

pub fn new(runtime: R) -> Self

Create a new runtime that wraps runtime, but overrides its view of time with a MockSleepProvider.

pub fn inner(&self) -> &R

Return a reference to the underlying runtime.

pub fn mock_sleep(&self) -> &MockSleepProvider

Return a reference to the MockSleepProvider

pub async fn advance(&self, dur: Duration)

See MockSleepProvider::advance()

pub fn jump_to(&self, new_wallclock: SystemTime)

See MockSleepProvider::jump_to()

Trait Implementations

impl<R: Clone + Runtime> Clone for MockSleepRuntime<R>

fn clone(&self) -> MockSleepRuntime<R>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<R: Runtime> SleepProvider for MockSleepRuntime<R>

type SleepFuture = Sleeping

A future returned by SleepProvider::sleep()

fn sleep(&self, dur: Duration) -> Self::SleepFuture

Return a future that will be ready after duration has elapsed.

fn now(&self) -> Instant

Return the SleepProvider’s view of the current instant.

fn wallclock(&self) -> SystemTime

Return the SleepProvider’s view of the current wall-clock time.

impl<R: Runtime> Spawn for MockSleepRuntime<R>

fn spawn_obj(&self, future: FutureObj<'static, ()>) -> Result<(), SpawnError>

Spawns a future that will be run to completion.

fn status(&self) -> Result<(), SpawnError>

Determines whether the executor is able to spawn new tasks.

impl<R: Runtime> SpawnBlocking for MockSleepRuntime<R>

fn block_on<F: Future>(&self, future: F) -> F::Output

Run future until it is ready, and return its output.

impl<R: Runtime> TcpProvider for MockSleepRuntime<R>

type TcpStream = R::TcpStream

The type for the TCP connections returned by Self::connect().

type TcpListener = R::TcpListener

The type for the TCP listeners returned by Self::listen().

fn connect<'life0, 'life1, 'async_trait>(
    &'life0 self,
    addr: &'life1 SocketAddr
) -> Pin<Box<dyn Future<Output = IoResult<Self::TcpStream>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Launch a TCP connection to a given socket address.

fn listen<'life0, 'life1, 'async_trait>(
    &'life0 self,
    addr: &'life1 SocketAddr
) -> Pin<Box<dyn Future<Output = IoResult<Self::TcpListener>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Open a TCP listener on a given socket address.

impl<R: Runtime> TlsProvider for MockSleepRuntime<R>

type Connector = R::Connector

The Connector object that this provider can return.

type TlsStream = R::TlsStream

The type of the stream returned by that connector.

fn tls_connector(&self) -> Self::Connector

Return a TLS connector for use with this runtime.