fedimint-core 0.9.1

fedimint-core provides common code used by both client and server.
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
30
31
32
33
34
35
36
37

//! Abstraction over an executor so we can spawn tasks under WASM the same way
//! we do usually.

use std::future::Future;

use fedimint_logging::LOG_RUNTIME;
pub use n0_future::task::{JoinError, JoinHandle};
pub use n0_future::time::{Duration, Elapsed, Instant, sleep, sleep_until, timeout};
use tracing::Instrument;

use crate::task::MaybeSend;

pub fn spawn<F, T>(name: &str, future: F) -> JoinHandle<T>
where
    F: Future<Output = T> + 'static + MaybeSend,
    T: MaybeSend + 'static,
{
    let span = tracing::debug_span!(target: LOG_RUNTIME, parent: None, "spawn", task = name);
    n0_future::task::spawn(future.instrument(span))
}

// Note: These functions only exist on non-wasm platforms and you need to handle
// them conditionally at the call site of packages that compile on wasm
#[cfg(not(target_family = "wasm"))]
pub fn block_in_place<F, R>(f: F) -> R
where
    F: FnOnce() -> R,
{
    // nosemgrep: ban-raw-block-in-place
    tokio::task::block_in_place(f)
}

#[cfg(not(target_family = "wasm"))]
pub fn block_on<F: Future>(future: F) -> F::Output {
    // nosemgrep: ban-raw-block-on
    tokio::runtime::Handle::current().block_on(future)
}