web-socket-io 0.1.0

A protocol for event-driven, bi-directional communication between clients and servers
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

use std::fmt;

/// Represents a connection closure with a code and reason.
#[derive(Debug)]
pub struct ConnClose {
    /// represents the status code of the close event.
    pub code: u16,
    /// represents the reason for the close event
    pub reason: Box<str>,
}

impl fmt::Display for ConnClose {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        write!(f, "{}", self.reason)
    }
}

impl std::error::Error for ConnClose {}

/// Errors that can occur during notification.
#[derive(Debug)]
pub enum NotifyError {
    /// The event name exceeds the allowed size (255 bytes).
    EventNameTooBig,
    /// The receiver channel has been closed.
    ReceiverClosed,
}

impl fmt::Display for NotifyError {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
            NotifyError::EventNameTooBig => write!(f, "event name exceeds the allowed length."),
            NotifyError::ReceiverClosed => write!(f, "receiver is already closed."),
        }
    }
}

impl std::error::Error for NotifyError {}


/// Indicates that the receiver half is closed.
#[derive(Debug)]
pub struct ReceiverClosed;

impl fmt::Display for ReceiverClosed {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        write!(f, "receiver is already closed.")
    }
}
impl std::error::Error for ReceiverClosed {}