Struct tor_rtmock::MockNetRuntime
source · pub struct MockNetRuntime<R: Runtime> { /* private fields */ }
Expand description
A wrapper Runtime that overrides the SleepProvider trait for the underlying runtime.
Implementations§
source§impl<R: Runtime> MockNetRuntime<R>
impl<R: Runtime> MockNetRuntime<R>
sourcepub fn new(runtime: R, net: MockNetProvider) -> Self
pub fn new(runtime: R, net: MockNetProvider) -> Self
Create a new runtime that wraps runtime
, but overrides
its view of the network with a MockNetProvider
, net
.
sourcepub fn mock_net(&self) -> &MockNetProvider
pub fn mock_net(&self) -> &MockNetProvider
Return a reference to the MockNetProvider
Trait Implementations§
source§impl<R: Runtime> BlockOn for MockNetRuntime<R>
impl<R: Runtime> BlockOn for MockNetRuntime<R>
source§impl<R: Clone + Runtime> Clone for MockNetRuntime<R>
impl<R: Clone + Runtime> Clone for MockNetRuntime<R>
source§fn clone(&self) -> MockNetRuntime<R>
fn clone(&self) -> MockNetRuntime<R>
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl<R: Runtime> CoarseTimeProvider for MockNetRuntime<R>
impl<R: Runtime> CoarseTimeProvider for MockNetRuntime<R>
source§fn now_coarse(&self) -> CoarseInstant
fn now_coarse(&self) -> CoarseInstant
Return the
CoarseTimeProvider
’s view of the current instant. Read moresource§impl<R: Runtime> SleepProvider for MockNetRuntime<R>
impl<R: Runtime> SleepProvider for MockNetRuntime<R>
§type SleepFuture = <R as SleepProvider>::SleepFuture
type SleepFuture = <R as SleepProvider>::SleepFuture
A future returned by
SleepProvider::sleep()
source§fn sleep(&self, dur: Duration) -> Self::SleepFuture
fn sleep(&self, dur: Duration) -> Self::SleepFuture
Return a future that will be ready after
duration
has
elapsed.source§fn wallclock(&self) -> SystemTime
fn wallclock(&self) -> SystemTime
Return the SleepProvider’s view of the current wall-clock time. Read more
source§fn block_advance<T: Into<String>>(&self, reason: T)
fn block_advance<T: Into<String>>(&self, reason: T)
Signify that a test running under mock time shouldn’t advance time yet, with a given
unique reason string. This is useful for making sure (mock) time doesn’t advance while
things that might require some (real-world) time to complete do so, such as spawning a task
on another thread. Read more
source§fn release_advance<T: Into<String>>(&self, reason: T)
fn release_advance<T: Into<String>>(&self, reason: T)
Signify that the reason to withhold time advancing provided in a call to
block_advance
no
longer exists, and it’s fine to move time forward if nothing else is blocking advances. Read moresource§fn allow_one_advance(&self, dur: Duration)
fn allow_one_advance(&self, dur: Duration)
Allow a test running under mock time to advance time by the provided duration, even if the
above
block_advance
API has been used. Read moresource§impl<R: Runtime> Spawn for MockNetRuntime<R>
impl<R: Runtime> Spawn for MockNetRuntime<R>
source§impl<R: Runtime> TcpProvider for MockNetRuntime<R>
impl<R: Runtime> TcpProvider for MockNetRuntime<R>
§type TcpStream = <MockNetProvider as TcpProvider>::TcpStream
type TcpStream = <MockNetProvider as TcpProvider>::TcpStream
The type for the TCP connections returned by
Self::connect()
.§type TcpListener = <MockNetProvider as TcpProvider>::TcpListener
type TcpListener = <MockNetProvider as TcpProvider>::TcpListener
The type for the TCP listeners returned by
Self::listen()
.source§fn connect<'life0, 'life1, 'async_trait>(
&'life0 self,
addr: &'life1 SocketAddr
) -> Pin<Box<dyn Future<Output = IoResult<Self::TcpStream>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn connect<'life0, 'life1, 'async_trait>(
&'life0 self,
addr: &'life1 SocketAddr
) -> Pin<Box<dyn Future<Output = IoResult<Self::TcpStream>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Launch a TCP connection to a given socket address. Read more
source§fn listen<'life0, 'life1, 'async_trait>(
&'life0 self,
addr: &'life1 SocketAddr
) -> Pin<Box<dyn Future<Output = IoResult<Self::TcpListener>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn listen<'life0, 'life1, 'async_trait>(
&'life0 self,
addr: &'life1 SocketAddr
) -> Pin<Box<dyn Future<Output = IoResult<Self::TcpListener>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Open a TCP listener on a given socket address.
source§impl<R: Runtime> TlsProvider<<MockNetProvider as TcpProvider>::TcpStream> for MockNetRuntime<R>
impl<R: Runtime> TlsProvider<<MockNetProvider as TcpProvider>::TcpStream> for MockNetRuntime<R>
§type Connector = <MockNetProvider as TlsProvider<<MockNetProvider as TcpProvider>::TcpStream>>::Connector
type Connector = <MockNetProvider as TlsProvider<<MockNetProvider as TcpProvider>::TcpStream>>::Connector
The Connector object that this provider can return.
§type TlsStream = <MockNetProvider as TlsProvider<<MockNetProvider as TcpProvider>::TcpStream>>::TlsStream
type TlsStream = <MockNetProvider as TlsProvider<<MockNetProvider as TcpProvider>::TcpStream>>::TlsStream
The type of the stream returned by that connector.
source§fn tls_connector(&self) -> Self::Connector
fn tls_connector(&self) -> Self::Connector
Return a TLS connector for use with this runtime.
source§impl<R: Runtime> UdpProvider for MockNetRuntime<R>
impl<R: Runtime> UdpProvider for MockNetRuntime<R>
§type UdpSocket = <MockNetProvider as UdpProvider>::UdpSocket
type UdpSocket = <MockNetProvider as UdpProvider>::UdpSocket
The type of Udp Socket returned by
Self::bind()
Auto Trait Implementations§
impl<R> Freeze for MockNetRuntime<R>where
R: Freeze,
impl<R> RefUnwindSafe for MockNetRuntime<R>where
R: RefUnwindSafe,
impl<R> Send for MockNetRuntime<R>
impl<R> Sync for MockNetRuntime<R>
impl<R> Unpin for MockNetRuntime<R>where
R: Unpin,
impl<R> UnwindSafe for MockNetRuntime<R>where
R: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§impl<T> SleepProviderExt for Twhere
T: SleepProvider,
impl<T> SleepProviderExt for Twhere
T: SleepProvider,
source§fn timeout<F>(
&self,
duration: Duration,
future: F
) -> Timeout<F, Self::SleepFuture>where
F: Future,
fn timeout<F>(
&self,
duration: Duration,
future: F
) -> Timeout<F, Self::SleepFuture>where
F: Future,
source§fn sleep_until_wallclock(
&self,
when: SystemTime
) -> SleepUntilWallclock<'_, Self>
fn sleep_until_wallclock( &self, when: SystemTime ) -> SleepUntilWallclock<'_, Self>
Pause until the wall-clock is at
when
or later, trying to
recover from clock jumps. Read moresource§impl<Sp> SpawnExt for Sp
impl<Sp> SpawnExt for Sp
source§fn spawn<Fut>(&self, future: Fut) -> Result<(), SpawnError>
fn spawn<Fut>(&self, future: Fut) -> Result<(), SpawnError>
Available on crate feature
alloc
only.Spawns a task that polls the given future with output
()
to
completion. Read moresource§fn spawn_with_handle<Fut>(
&self,
future: Fut
) -> Result<RemoteHandle<<Fut as Future>::Output>, SpawnError>
fn spawn_with_handle<Fut>( &self, future: Fut ) -> Result<RemoteHandle<<Fut as Future>::Output>, SpawnError>
Available on crate features
channel
and std
only.Spawns a task that polls the given future to completion and returns a
future that resolves to the spawned future’s output. Read more