pax-compiler 0.38.3

Compiler APIs for parsing and building Pax projects into application executables
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

use actix_http::ws::Item;
use actix_web_actors::ws;

pub struct SocketMessageAccumulator {
    partial_binary: Vec<u8>,
}

impl SocketMessageAccumulator {
    pub fn new() -> Self {
        Self {
            partial_binary: Vec::new(),
        }
    }
    pub fn process(&mut self, message: ws::Message) -> Result<Option<Vec<u8>>, String> {
        match message {
            ws::Message::Continuation(item) => {
                match item {
                    Item::FirstText(_) => return Err("no text support".to_string()),
                    Item::FirstBinary(first) => self.partial_binary.extend_from_slice(&first),
                    Item::Continue(b) => self.partial_binary.extend_from_slice(&b),
                    Item::Last(b) => {
                        self.partial_binary.extend_from_slice(&b);
                        let data = std::mem::take(&mut self.partial_binary);
                        return Ok(Some(data));
                    }
                };
            }
            ws::Message::Text(_) => return Err("no text support".to_string()),
            ws::Message::Binary(binary) => return Ok(Some(binary.to_vec())),
            // TODO
            ws::Message::Ping(_) => (),
            ws::Message::Pong(_) => (),
            ws::Message::Close(_) => (),
            ws::Message::Nop => (),
        };
        Ok(None)
    }
}