websocket_rs/
message.rs

1use bytes::Bytes;
2
3use crate::Opcode;
4
5#[derive(Debug)]
6pub struct Message {
7    pub opcode: Opcode,
8    pub payload: Bytes,
9}
10
11impl Message {
12    pub fn text(text: &str) -> Self {
13        Self {
14            opcode: Opcode::Text,
15            payload: Bytes::copy_from_slice(text.as_bytes()),
16        }
17    }
18
19    pub fn close() -> Self {
20        Self {
21            opcode: Opcode::Close,
22            payload: Bytes::new(),
23        }
24    }
25
26    pub fn pong() -> Self {
27        Self {
28            opcode: Opcode::Pong,
29            payload: Bytes::new(),
30        }
31    }
32}