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

use futures::{Sink, Stream};
use std::future::Future;

use crate::RPCResult;

/// Transport input item
pub type TransportInput<E> = Result<RPCData, E>;

/// Transport output item.
pub type RPCData = bytes::Bytes;

/// Define abstract transport channel for [`crate::Client`] and [`crate::Server`]
pub trait TransportChannel: 'static {
    /// Transport channel error type.
    type SinkError: std::error::Error + 'static + Sync + Send;

    type StreamError: std::error::Error + 'static + Sync + Send;

    /// Input stream must support [`Send`] + [`Sync`]
    type Input: Stream<Item = TransportInput<Self::StreamError>> + Unpin + Send + 'static;

    type Output: Sink<RPCData, Error = Self::SinkError> + Unpin + Send + 'static;

    fn spawn<Fut>(future: Fut)
    where
        Fut: Future<Output = RPCResult<()>> + Send + 'static;

    fn framed(self) -> (Self::Input, Self::Output);
}