lazily 0.55.0

Lazy reactive signals with dependency tracking and cache invalidation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

#![cfg(feature = "thread-safe")]

use lazily::ThreadSafeContext;

#[tokio::main(flavor = "multi_thread")]
async fn main() {
    let ctx = ThreadSafeContext::new();
    let input = ctx.source(20usize);
    let doubled = ctx.computed(move |ctx| ctx.get(&input) * 2);

    let worker_ctx = ctx.clone();
    let result = tokio::task::spawn_blocking(move || {
        worker_ctx.set(&input, 21);
        worker_ctx.get(&doubled)
    })
    .await
    .expect("blocking task should finish");

    println!("doubled={result}");
}