kernel 1.1.0

Abstract Reactive Streams
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
47
48
49
50
51
52
53
54
55
56
57
58


use commands::ast::*;
use std::cell::UnsafeCell;
use streams::otree::*;

#[derive(Debug, Clone)]
pub struct Entry<'a>(u16, &'a AST<'a>);

#[derive(Debug)]
pub struct Environment<'a> {
    pub tree: UnsafeCell<Tree<'a, Entry<'a>>>,
}

impl<'a> Environment<'a> {
    pub fn new_root() -> Result<Environment<'a>, Error> {
        let mut s = Tree::with_capacity(10000 as usize);
        Ok(Environment { tree: UnsafeCell::new(s) })
    }

    pub fn last(&'a self) -> &'a Node<'a> {
        let tree = unsafe { &*self.tree.get() };
        tree.last_node()
    }

    pub fn dump(&'a self) {
        let tree = unsafe { &*self.tree.get() };
        tree.dump()
    }

    pub fn len(&'a self) -> (usize,usize) {
        let tree = unsafe { &*self.tree.get() };
        tree.len()
    }

    pub fn new_child(&'a self, n: &'a Node<'a>) -> &'a Node<'a> {
        let tree = unsafe { &mut *self.tree.get() };
        tree.append_node(n)
    }

    pub fn define(&'a self, key: u16, value: &'a AST<'a>) -> Result<(), Error> {
        let tree = unsafe { &mut *self.tree.get() };
        tree.insert(Entry(key, value));
        Ok(())
    }

    pub fn get(&'a self, key: u16, n: &'a Node<'a>) -> Option<(&'a AST, &Node<'a>)> {
        let tree = unsafe { &mut *self.tree.get() };
        match tree.get(n, |e| e.0 == key) {
            Some(x) => Some(((x.0).1, x.1)),
            None => None,
        }
    }

    pub fn clean(&self) -> usize {
        let tree = unsafe { &mut *self.tree.get() };
        tree.clean()
    }
}