ic-query 0.5.18

Internet Computer query library for NNS, SNS, ICRC, and related public network metadata
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

//! Module: runtime
//!
//! Responsibility: run async query flows from synchronous report builders.
//! Does not own: source-specific errors, command parsing, or report rendering.
//! Boundary: creates a current-thread Tokio runtime for one query flow.

use std::{future::Future, io};
use thiserror::Error as ThisError;

///
/// RuntimeError
///
/// Error returned while creating the local Tokio runtime.
///

#[derive(Debug, ThisError)]
pub enum RuntimeError {
    #[error("failed to create Tokio current-thread runtime: {source}")]
    CreateTokioRuntime { source: io::Error },
}

pub fn block_on_current_thread<F>(future: F) -> Result<F::Output, RuntimeError>
where
    F: Future,
{
    let runtime = tokio::runtime::Builder::new_current_thread()
        .enable_all()
        .build()
        .map_err(|source| RuntimeError::CreateTokioRuntime { source })?;
    Ok(runtime.block_on(future))
}