Struct CmdSend

pub struct CmdSend<R: CmdTunnelRead, W: CmdTunnelWrite, LEN, CMD>
where
    LEN: RawEncode + for<'a> RawDecode<'a> + Copy + Send + Sync + 'static + FromPrimitive + ToPrimitive,
    CMD: RawEncode + for<'a> RawDecode<'a> + Copy + Send + Sync + 'static + Debug,
{ /* private fields */ }

Implementations

impl<R, W, LEN, CMD> CmdSend<R, W, LEN, CMD>

where R: CmdTunnelRead, W: CmdTunnelWrite, LEN: RawEncode + for<'a> RawDecode<'a> + Copy + Send + Sync + 'static + FromPrimitive + ToPrimitive, CMD: RawEncode + for<'a> RawDecode<'a> + Copy + Send + Sync + 'static + Debug,

pub fn new( tunnel_id: TunnelId, recv_handle: JoinHandle<CmdResult<()>>, write: WHalf<R, W>, ) -> Self

pub fn get_tunnel_id(&self) -> TunnelId

pub fn set_disable(&mut self)

pub async fn send( &mut self, cmd: CMD, version: u8, body: &[u8], ) -> CmdResult<()>

pub async fn send2( &mut self, cmd: CMD, version: u8, body: &[&[u8]], ) -> CmdResult<()>

Trait Implementations

impl<R, W, LEN, CMD> ClassifiedWorker<(PeerId, Option<TunnelId>)> for CmdSend<R, W, LEN, CMD>

where R: CmdTunnelRead, W: CmdTunnelWrite, LEN: RawEncode + for<'a> RawDecode<'a> + Copy + Send + Sync + 'static + FromPrimitive + ToPrimitive, CMD: RawEncode + for<'a> RawDecode<'a> + Copy + Send + Sync + 'static + Debug,

fn is_work(&self) -> bool

fn is_valid(&self, c: (PeerId, Option<TunnelId>)) -> bool

fn classification(&self) -> (PeerId, Option<TunnelId>)

impl<R, W, LEN, CMD> ClassifiedWorker<TunnelId> for CmdSend<R, W, LEN, CMD>

where R: CmdTunnelRead, W: CmdTunnelWrite, LEN: RawEncode + for<'a> RawDecode<'a> + Copy + Send + Sync + 'static + FromPrimitive + ToPrimitive, CMD: RawEncode + for<'a> RawDecode<'a> + Copy + Send + Sync + 'static + Debug,

fn is_work(&self) -> bool

fn is_valid(&self, c: TunnelId) -> bool

fn classification(&self) -> TunnelId

impl<R, W, LEN, CMD> Drop for CmdSend<R, W, LEN, CMD>

where R: CmdTunnelRead, W: CmdTunnelWrite, LEN: RawEncode + for<'a> RawDecode<'a> + Copy + Send + Sync + 'static + FromPrimitive + ToPrimitive, CMD: RawEncode + for<'a> RawDecode<'a> + Copy + Send + Sync + 'static + Debug,

fn drop(&mut self)

Executes the destructor for this type.