sfo-cmd-server 0.3.2

command server implement
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

use crate::PeerId;
use as_any::AsAny;
use sfo_split::{RHalf, Splittable, WHalf};
use std::any::Any;
use std::sync::Arc;
use tokio::io::{AsyncRead, AsyncWrite};

pub trait CmdTunnelMeta: Send + Sync + 'static {}

impl<T: Send + Sync + 'static> CmdTunnelMeta for T {}

pub trait CmdTunnelRead<M: CmdTunnelMeta>:
    Send + AsyncRead + 'static + Unpin + Any + AsAny
{
    fn get_local_peer_id(&self) -> PeerId;
    fn get_remote_peer_id(&self) -> PeerId;
    fn get_tunnel_meta(&self) -> Option<Arc<M>> {
        None
    }
}

pub trait CmdTunnelWrite<M: CmdTunnelMeta>:
    AsyncWrite + Send + 'static + Unpin + Any + AsAny
{
    fn get_local_peer_id(&self) -> PeerId;
    fn get_remote_peer_id(&self) -> PeerId;
    fn get_tunnel_meta(&self) -> Option<Arc<M>> {
        None
    }
}

pub type CmdTunnel<R, W> = Splittable<R, W>;
pub type CmdTunnelRHalf<R, W> = RHalf<R, W>;
pub type CmdTunnelWHalf<R, W> = WHalf<R, W>;