actrpc-transport 0.1.0

Transport abstractions and implementations for ActRPC.
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

mod http;
mod local_ipc;
mod stdio;
mod tcp;
mod web_socket;

pub use http::HttpJsonRpcClient;
pub use local_ipc::LocalIpcJsonRpcClient;
pub use stdio::StdioJsonRpcClient;
pub use tcp::TcpJsonRpcClient;
pub use web_socket::WebSocketJsonRpcClient;

use actrpc_core::json_rpc::JsonRpcMessage;
use std::{future::Future, pin::Pin, sync::Arc};

pub type JsonRpcClientFuture<'a, T> = Pin<Box<dyn Future<Output = T> + Send + 'a>>;

pub trait JsonRpcClient: Send + Sync {
    type Error: Send + Sync + 'static;

    fn send<'a>(
        &'a self,
        message: JsonRpcMessage,
    ) -> JsonRpcClientFuture<'a, Result<JsonRpcMessage, Self::Error>>;
}

impl<T> JsonRpcClient for Arc<T>
where
    T: JsonRpcClient + ?Sized,
{
    type Error = T::Error;

    fn send<'a>(
        &'a self,
        message: JsonRpcMessage,
    ) -> JsonRpcClientFuture<'a, Result<JsonRpcMessage, Self::Error>> {
        (**self).send(message)
    }
}