jsonrpc-rs 0.1.6

Futures base jsonrpc server/client framework
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

use futures::{channel::mpsc::Receiver, SinkExt, StreamExt};

use crate::{
    channel::{RPCData, TransportChannel},
    map_error, RPCResult, Request,
};

use super::user_event::RPCCompletedQ;

pub async fn send_loop<C: TransportChannel, S: AsRef<str>>(
    client_id: S,
    mut output: C::Output,
    mut output_receiver: Receiver<RPCData>,
    completed_q: RPCCompletedQ,
) -> RPCResult<()> {
    while let Some(item) = output_receiver.next().await {
        match output.send(item.clone()).await {
            Err(err) => {
                let request: Request<String, serde_json::Value> =
                    serde_json::from_slice(&item).expect("Parse send json error");

                log::error!("RPC client send msg error, {}", err);

                if let Some(id) = request.id {
                    completed_q.complete_one(id, Err(map_error(err)));
                }
            }
            _ => {}
        }
    }

    log::info!("rpc client {} send_loop stop.", client_id.as_ref());

    Ok(())
}