1use crate::PeerId;
2use as_any::AsAny;
3use sfo_split::{RHalf, Splittable, WHalf};
4use std::any::Any;
5use std::sync::Arc;
6use tokio::io::{AsyncRead, AsyncWrite};
7
8pub trait CmdTunnelMeta: Send + Sync + 'static {}
9
10impl<T: Send + Sync + 'static> CmdTunnelMeta for T {}
11
12pub trait CmdTunnelRead<M: CmdTunnelMeta>:
13 Send + AsyncRead + 'static + Unpin + Any + AsAny
14{
15 fn get_remote_peer_id(&self) -> PeerId;
16 fn get_tunnel_meta(&self) -> Option<Arc<M>> {
17 None
18 }
19}
20
21pub trait CmdTunnelWrite<M: CmdTunnelMeta>:
22 AsyncWrite + Send + 'static + Unpin + Any + AsAny
23{
24 fn get_remote_peer_id(&self) -> PeerId;
25 fn get_tunnel_meta(&self) -> Option<Arc<M>> {
26 None
27 }
28}
29
30pub type CmdTunnel<R, W> = Splittable<R, W>;
31pub type CmdTunnelRHalf<R, W> = RHalf<R, W>;
32pub type CmdTunnelWHalf<R, W> = WHalf<R, W>;