net-socket-packet 0.1.0

net-socket-packet
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

use std::collections::HashMap;

use js_sys::ArrayBuffer;
use wasm_bindgen::JsValue;

use super::packet::Packet;
pub trait PacketListener {
    fn on_packet_arrived(&mut self,opcode:u8,data:ArrayBuffer)->bool;
    fn add_handler_fun(&mut self,opcode:u8,callback:js_sys::Function);
}

pub struct PacketHandler{
    opcode_hashmap:HashMap<u8,js_sys::Function>,
}

impl PacketListener for PacketHandler{
    fn on_packet_arrived(&mut self,opcode:u8,data: ArrayBuffer)->bool{
        if self.opcode_hashmap.is_empty() == true {
            return false
        }

        let call_back_option = self.opcode_hashmap.get(
            &opcode
         );
         if call_back_option == None {
            let call_back:& js_sys::Function = call_back_option.unwrap();
            call_back.call1(&JsValue::NULL,&JsValue::from(data));
            // call_back.call(this, packet);
            // console.info(`Finish handle OPCODE: 0x${packet.opcode.toString(16)} / ${packet.opcode.toString()}`);
            return true;
         }
        false
    }

    fn add_handler_fun(&mut self,opcode: u8,callback:js_sys::Function){
        if self.opcode_hashmap.is_empty() == true {
            self.opcode_hashmap = HashMap::new();
        }
        self.opcode_hashmap.insert(opcode, callback);
    }
}

// 密封特性
pub(crate) mod private {

    #[doc(hidden)]
    pub trait FooPrivate<Arg> {
        fn foo(&self, arg: Arg);
    }

}

pub trait Foo<Arg>: private::FooPrivate<Arg> {

    /* other public methods */

}