mosaik 0.3.19

A Rust runtime for building self-organizing, leaderless distributed systems.
Documentation 
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

use {
	core::{
		pin::Pin,
		task::{Context, Poll, Waker},
		time::Duration,
	},
	derive_more::Debug,
	futures::TryFutureExt,
	std::{process::Output, sync::OnceLock},
	tokio::time::Timeout,
};

pub fn poll_once<T, F>(f: &mut F) -> Poll<T>
where
	F: Future<Output = T> + Unpin,
{
	let waker = Waker::noop();
	let mut context = Context::from_waker(waker);
	Pin::new(f).poll(&mut context)
}

/// A future that never completes and returns nothing.
///
/// This is sometimes useful during tests development to
/// keep the test running and observe logs.
pub async fn forever() -> ! {
	futures::future::pending::<()>().await;
	unreachable!()
}