t2_bus 0.1.0

An inter- or intra-process message bus supporting publish/subscribe and request/response.
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

use crate::{err::*, transport::cbor_codec::CborCodec};
use super::protocol::Msg;

pub mod cbor_codec;
pub mod memory;
pub mod unix;
pub mod tcp;
pub mod tls;

pub trait Transport<TSend, TRecv>:
    'static
    + futures::Stream<Item = BusResult<Msg<TRecv>>>
    + futures::Sink<Msg<TSend>, Error = BusError>
    + Send
    + Unpin
{
}

impl<TSend, TRecv, TSocket> Transport<TSend, TRecv>
    for tokio_util::codec::Framed<TSocket, CborCodec<Msg<TSend>, Msg<TRecv>>>
where
    TSend: 'static + serde::Serialize + Send,
    TRecv: 'static + serde::de::DeserializeOwned + Send,
    TSocket: 'static + Send + Unpin + tokio::io::AsyncWrite + tokio::io::AsyncRead
{
}