blob: 784929e23c5021bb2068169d560a84200c909d77 (
plain)
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
|
//! Entry points for use with async_std runtimes.
pub use crate::impls::async_std::create_runtime as create_async_std_runtime;
use crate::{Runtime, SpawnBlocking};
/// Return a new async-std-based [`Runtime`].
///
/// Generally you should call this function only once, and then use
/// [`Clone::clone()`] to create additional references to that
/// runtime.
pub fn create_runtime() -> std::io::Result<impl Runtime> {
Ok(create_async_std_runtime())
}
/// Try to return an instance of the currently running async_std
/// [`Runtime`].
pub fn current_runtime() -> std::io::Result<impl Runtime> {
// In async_std, the runtime is a global singleton.
create_runtime()
}
/// Run a test function using a freshly created async_std runtime.
pub fn test_with_runtime<P, F, O>(func: P) -> O
where
P: FnOnce(async_executors::AsyncStd) -> F,
F: futures::Future<Output = O>,
{
let runtime = create_async_std_runtime();
runtime.block_on(func(runtime))
}
|
