effect-rs 0.1.0

A high-performance, strictly-typed, functional effect system for Rust.
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

use crate::core::{Effect, EnvRef, Exit};
use tokio::runtime::Runtime as TokioRuntime;
use tracing::Instrument;

pub struct Runtime {
    pub(crate) rt: tokio::runtime::Runtime,
}

impl Default for Runtime {
    fn default() -> Self {
        Self::new()
    }
}

impl Runtime {
    pub fn new() -> Self {
        Self {
            rt: TokioRuntime::new().unwrap(),
        }
    }
    pub fn block_on<R, E, A>(&self, effect: Effect<R, E, A>, env: R) -> Exit<E, A>
    where
        R: Send + Sync + 'static,
        E: Send + Sync + 'static,
        A: Send + Sync + 'static,
    {
        self.rt.block_on(async move {
            let ctx = crate::core::Ctx::new(); // Use Ctx::new() which sets defaults including locals

            let result = (effect.inner)(EnvRef { value: env }, ctx.clone())
                .instrument(tracing::info_span!("runtime_execution"))
                .await;
            ctx.scope.close(crate::core::ScopeExit::from(&result)).await;
            result
        })
    }
}