flyer 2.1.4

HTTP framework for rust
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

use async_std::task::block_on;

pub(crate) const SEC_WEB_SOCKET_ACCEPT_STATIC: &str = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";

pub(crate) type OnEvent = dyn Fn(Event, &mut Box<dyn Writer + Send + Sync>) + Send + Sync + 'static;

#[derive(Debug)]
pub struct Reason {
    pub code: u16,
    pub message: String,
}

pub enum Event {
    Ready(),
    Text(Vec<u8>),
    Binary(Vec<u8>),
    Ping(Vec<u8>),
    Pong(Vec<u8>),
    Close(Option<Reason>),
}

pub trait Writer {
    fn write(&mut self, data: Vec<u8>);
    fn write_binary(&mut self, data: Vec<u8>);
    fn ping(&mut self, data: Vec<u8>);
    fn pong(&mut self, data: Vec<u8>);
    fn close(&mut self);
}

pub struct Ws {
    pub(crate) event: Option<Box<OnEvent>>,
}

impl Ws {
    pub fn new() -> Self {
        return Ws {
            event: None
        } 
    }

    pub fn on<C>(&mut self, callback: C)
    where
        C: for<'a> AsyncFn(Event, &'a mut Box<dyn Writer + Send + Sync>) -> () + Send + Sync + 'static
    {
        self.event = Some(Box::new(move |event, writer| block_on(callback(event, writer))));
    }
}