zbus_lib/wsocket/
mod.rs

1use std::sync::mpsc::Sender;
2
3use ws::{CloseCode, Handler, Sender as WsCmd};
4
5pub use component::WsClient;
6pub use handler::WsClientHandler;
7
8use crate::err::{OkResult, ZbusErr, ZbusResult};
9use crate::message::{Message, Request, Response};
10
11mod handler;
12mod component;
13
14pub enum Instruct {
15    Connected(WsCmd),
16    Connect,
17    Delivery(Message, Option<Sender<OkResult>>),
18    //投递消息
19    Receive(Message),
20    //接收到消息
21    Response(String, Option<Sender<ZbusResult<Response>>>),
22    //获取response消息，response管理器目前放在一起
23    Close(Option<Sender<OkResult>>),
24    Closed,
25    Exit,
26    IsClose(Option<Sender<OkResult>>),
27}
28
29
zbus_lib/wsocket/mod.rs

zbus_lib/wsocket/
mod.rs
