edgy-s 1.4.0

A minimalist WebSocket bidirectional RPC framework for building microservice applications
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

use {
    super::{super::types::ReqId, handler::WsCall},
    std::io::Result as IoResult,
    tokio::{
        sync::{mpsc::Sender as MpscSender, oneshot::Sender as OneshotSender},
        task::JoinHandle,
    },
    tokio_tungstenite::tungstenite::Message,
};

#[derive(Debug)]
pub enum Command {
    AddWsRoute {
        path: String,
        stream: MpscSender<WsCall>,
        task: JoinHandle<()>,
        opt_return: OneshotSender<IoResult<()>>,
    },

    RemoveWsRoute {
        path: String,
        opt_return: OneshotSender<IoResult<()>>,
    },

    CallRemotely {
        path: String,
        id: ReqId,
        msg: Message,
        opt_return: OneshotSender<IoResult<Message>>,
    },
}