thruster-socketio 0.2.0

A SocketIO layer built on Thruster
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

use crate::socketio::SocketIOHandler;
use std::fmt;

#[derive(Clone, Debug)]
pub enum SocketIOMessage {
    Message(String, String), // Event, Message
    SendMessage(String, String),
    SendBinaryMessage(String, Vec<u8>),
    Join(String),
    Leave(String),
    AddListener(String, SocketIOHandler),
    Close,
    Pong,
    WsPong,
}

impl fmt::Display for SocketIOMessage {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
            SocketIOMessage::Message(event, message) => {
                write!(f, "SocketIOMessage::Message({}, {})", event, message)
            }
            SocketIOMessage::SendMessage(event, message) => {
                write!(f, "SocketIOMessage::SendMessage({}, {})", event, message)
            }
            SocketIOMessage::SendBinaryMessage(event, message) => {
                write!(f, "SocketIOMessage::SendBinaryMessage({}, {:?})", event, message)
            }
            SocketIOMessage::Join(val) => write!(f, "SocketIOMessage::Join({})", val),
            SocketIOMessage::Leave(val) => write!(f, "SocketIOMessage::Leave({})", val),
            SocketIOMessage::AddListener(val, _handler) => write!(f, "AddListener({})", val),
            SocketIOMessage::Close => write!(f, "SocketIOMessage::Close"),
            SocketIOMessage::Pong => write!(f, "SocketIOMessage::Pong"),
            SocketIOMessage::WsPong => write!(f, "SocketIOMessage::WsPong"),
        }
    }
}