thal 0.0.1

Reactive semantic runtime — molecules, reactions, and effect actors for building LLM-backed applications as dataflow programs.
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

use std::time::Duration;
use thal::Reactor;

#[tokio::test(flavor = "multi_thread")]
async fn timer_counter_increments() {
    let program = thal::load("examples/timer-counter.thal").expect("load");
    let reactor = Reactor::new(program);
    let store = reactor.store();
    let task = tokio::spawn(reactor.run());

    tokio::time::sleep(Duration::from_millis(550)).await;
    task.abort();

    let counter = store
        .get_singleton("Counter")
        .expect("Counter molecule was emitted");
    let value = counter
        .fields
        .get("value")
        .expect("value field present")
        .as_int()
        .expect("value is Int");
    assert!(
        value >= 4,
        "expected at least 4 ticks in 550ms, got {value}"
    );
}