Struct Websocket 

pub struct Websocket {
    pub send: Option<Sender<Message>>,
    pub key: String,
    pub deflate: DeflateConfig,
    /* private fields */
}

Fields

send: Option<Sender<Message>>

key: String

deflate: DeflateConfig

Implementations

impl Websocket

pub fn http(request: Request, response: Response) -> Self

pub fn new(request: Request, response: Response) -> Self

pub fn send(&self, data: &JsonValue)

pub fn send_binary(&self, data: &[u8])

pub fn ping(&self, payload: &[u8])

pub fn close(&self, code: CloseCode, reason: &str)

pub fn online_users(&self) -> usize

pub fn is_connected(&self) -> bool

pub fn handle(&mut self) -> Result<(), HttpError>

Trait Implementations

impl Clone for Websocket

fn clone(&self) -> Websocket

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Websocket

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Handler for Websocket

fn on_request(&mut self, _request: Request, _response: &mut Response)

请求 处理

fn on_frame(&mut self) -> Result<(), HttpError>

fn on_options(&mut self, response: &mut Response)

预检请求处理 OPTIONS

fn on_response(&mut self, response: &mut Response)

响应 处理

fn on_open(&mut self) -> Result<(), HttpError>

握手监听

fn on_message(&mut self, _msg: Message) -> Result<(), HttpError>

接收到消息

fn on_close(&mut self, _code: CloseCode, _reason: &str)

关闭监听

fn on_error(&mut self, _err: ErrorCode)

错误监听

fn on_shutdown(&mut self)

关机监听