cram 0.1.2

Cram realy awesome middleware
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 crate::serializers;
use super::Node;

use crossbeam::Sender;
use std::collections::HashMap;

impl Node{
    pub fn new( io_port : usize, io_channel : Sender<(i8, Vec<u8>, String)> ) -> Node{
        Node{
            io : io_channel,
            io_port : io_port,
            controllers : HashMap::new(),
        }
    }

    pub fn send(&self, msg : Vec<u8>, address : String){
        self.io.send( (0,msg,address)).unwrap();
    }   

    pub fn send_with_label(&self, msg : Vec<u8>, label : String, address : String){
        let new_msg = serializers::serialize_label_message(label, msg);
        self.io.send( (1,new_msg,address)).unwrap();
    }

    pub fn get_io_port(&self) -> usize {
        self.io_port
    }

}

impl Clone for Node {
    
    fn clone(&self) -> Node {
        let mut hash = HashMap::new();
        
        for (k,v) in &self.controllers{
            hash.insert( *k, v.clone() );
        }

        Node{
            io: self.io.clone(),
            io_port : self.io_port,
            controllers : hash,
        }
    }
}