harn-vm 0.10.173

Async bytecode virtual machine for the Harn programming language
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

/// Construct a fresh current-thread runtime with timers and IO enabled.
#[track_caller]
pub(crate) fn current_thread_runtime() -> tokio::runtime::Runtime {
    tokio::runtime::Builder::new_current_thread()
        .enable_all()
        .build()
        .expect("test runtime builds")
}

#[cfg(test)]
mod tests {
    use super::current_thread_runtime;
    use futures::FutureExt;

    #[test]
    fn current_thread_runtime_supports_io_and_paused_timers() {
        current_thread_runtime().block_on(async {
            assert!(matches!(
                tokio::runtime::Handle::current().runtime_flavor(),
                tokio::runtime::RuntimeFlavor::CurrentThread
            ));
            let listener = tokio::net::TcpListener::bind((std::net::Ipv4Addr::LOCALHOST, 0))
                .await
                .expect("listen on loopback");
            let (client, server) = tokio::join!(
                tokio::net::TcpStream::connect(listener.local_addr().expect("local address")),
                listener.accept()
            );
            let _client = client.expect("connect loopback client");
            let (_server, _) = server.expect("accept loopback client");
            tokio::time::pause();
            let mut ticks = tokio::time::interval(std::time::Duration::from_secs(1));
            ticks.tick().await;
            assert!(ticks.tick().now_or_never().is_none());
            tokio::time::advance(std::time::Duration::from_secs(2)).await;
            assert!(ticks.tick().now_or_never().is_some());
        });
    }
}