zero4rs 2.0.0

zero4rs is a powerful, pragmatic, and extremely fast web 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
48
49
50
51
52

use actix::Message as ActixMessage;
use actix::Recipient;

use crate::websocket::devstreams::ConnectId;
use crate::websocket::devstreams::OutputMessage;
use crate::websocket::devstreams::OutputMessageType;

// WsConn 将此消息发送到大厅，表示“请让我加入”
#[derive(ActixMessage)]
#[rtype(result = "()")]
pub struct Connect {
    pub addr: Recipient<OutputMessage>,
    pub id: ConnectId,
}

// WsConn 将其发送到大厅，表示“请带我出去”
#[derive(ActixMessage)]
#[rtype(result = "()")]
pub struct Disconnect {
    pub id: ConnectId,
}

// 广播一条消息
#[derive(ActixMessage)]
#[rtype(result = "()")]
pub struct Broadcast {
    pub ty: OutputMessageType,
    pub msg: String,
}

#[derive(ActixMessage)]
#[rtype(result = "()")]
pub struct Subscribe {
    pub id: ConnectId,
    pub channel: SubscribeChannel,
}

#[derive(serde::Serialize, serde::Deserialize, Clone, strum_macros::EnumString)]
#[strum(ascii_case_insensitive)]
pub enum SubscribeChannel {
    ServerTime,
    Startup,
}

impl std::fmt::Display for SubscribeChannel {
    fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
        match self {
            SubscribeChannel::ServerTime => write!(f, "ServerTime"),
            SubscribeChannel::Startup => write!(f, "Startup"),
        }
    }
}