cljrs-runtime 0.1.245

clojurust runtime: environment, builtins, tree-walking interpreter, and tiered evaluation
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
38
39
40
41
42
43
44
45
46

use cljrs_value::Value;
use std::cell::RefCell;

struct TapState {
    fns: Vec<Value>,
}

thread_local! {
    static TAP: RefCell<TapState> = const { RefCell::new(TapState { fns: Vec::new() }) };
}

pub fn add_tap(f: Value) {
    TAP.with(|tap| {
        let mut state = tap.borrow_mut();
        if !state.fns.iter().any(|existing| existing == &f) {
            state.fns.push(f);
        }
    });
}

pub fn remove_tap(f: &Value) {
    TAP.with(|tap| {
        tap.borrow_mut().fns.retain(|existing| existing != f);
    });
}

pub fn send(val: Value) -> bool {
    let fns: Vec<Value> = TAP.with(|tap| tap.borrow().fns.clone());
    if fns.is_empty() {
        return false;
    }
    for f in &fns {
        let _ = crate::env::callback::invoke(f, vec![val.clone()]);
    }
    true
}

/// Trace all GcPtr values in the tap system as GC roots.
pub fn trace_roots(visitor: &mut cljrs_gc::MarkVisitor) {
    use cljrs_gc::Trace;
    TAP.with(|tap| {
        for val in &tap.borrow().fns {
            val.trace(visitor);
        }
    });
}