Trait CmdNode 

pub trait CmdNode<LEN: RawEncode + for<'a> RawDecode<'a> + Copy + RawFixedBytes + Sync + Send + 'static + FromPrimitive + ToPrimitive, CMD: RawEncode + for<'a> RawDecode<'a> + Copy + RawFixedBytes + Sync + Send + 'static + Eq + Hash, M: CmdTunnelMeta, S: CmdSend<M>, G: SendGuard<M, S>> {
    // Required methods
    fn register_cmd_handler(&self, cmd: CMD, handler: impl CmdHandler<LEN, CMD>);
    fn send<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        cmd: CMD,
        version: u8,
        body: &'life2 [u8],
    ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn send_with_resp<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        cmd: CMD,
        version: u8,
        body: &'life2 [u8],
        timeout: Duration,
    ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn send_parts<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        cmd: CMD,
        version: u8,
        body: &'life2 [&'life3 [u8]],
    ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;
    fn send_parts_with_resp<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        cmd: CMD,
        version: u8,
        body: &'life2 [&'life3 [u8]],
        timeout: Duration,
    ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;
    fn send_cmd<'life0, 'life1, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        cmd: CMD,
        version: u8,
        body: CmdBody,
    ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn send_cmd_with_resp<'life0, 'life1, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        cmd: CMD,
        version: u8,
        body: CmdBody,
        timeout: Duration,
    ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn send_by_specify_tunnel<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        tunnel_id: TunnelId,
        cmd: CMD,
        version: u8,
        body: &'life2 [u8],
    ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn send_by_specify_tunnel_with_resp<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        tunnel_id: TunnelId,
        cmd: CMD,
        version: u8,
        body: &'life2 [u8],
        timeout: Duration,
    ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn send_parts_by_specify_tunnel<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        tunnel_id: TunnelId,
        cmd: CMD,
        version: u8,
        body: &'life2 [&'life3 [u8]],
    ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;
    fn send_parts_by_specify_tunnel_with_resp<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        tunnel_id: TunnelId,
        cmd: CMD,
        version: u8,
        body: &'life2 [&'life3 [u8]],
        timeout: Duration,
    ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;
    fn send_cmd_by_specify_tunnel<'life0, 'life1, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        tunnel_id: TunnelId,
        cmd: CMD,
        version: u8,
        body: CmdBody,
    ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn send_cmd_by_specify_tunnel_with_resp<'life0, 'life1, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        tunnel_id: TunnelId,
        cmd: CMD,
        version: u8,
        body: CmdBody,
        timeout: Duration,
    ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn clear_all_tunnel<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_send<'life0, 'life1, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        tunnel_id: TunnelId,
    ) -> Pin<Box<dyn Future<Output = CmdResult<G>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;

    // Provided methods
    fn send2<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        cmd: CMD,
        version: u8,
        body: &'life2 [&'life3 [u8]],
    ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait { ... }
    fn send2_with_resp<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        cmd: CMD,
        version: u8,
        body: &'life2 [&'life3 [u8]],
        timeout: Duration,
    ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait { ... }
    fn send2_by_specify_tunnel<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        tunnel_id: TunnelId,
        cmd: CMD,
        version: u8,
        body: &'life2 [&'life3 [u8]],
    ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait { ... }
    fn send2_by_specify_tunnel_with_resp<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 self,
        peer_id: &'life1 PeerId,
        tunnel_id: TunnelId,
        cmd: CMD,
        version: u8,
        body: &'life2 [&'life3 [u8]],
        timeout: Duration,
    ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait { ... }
}

Required Methods

fn register_cmd_handler(&self, cmd: CMD, handler: impl CmdHandler<LEN, CMD>)

fn send<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, cmd: CMD, version: u8, body: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn send_with_resp<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, cmd: CMD, version: u8, body: &'life2 [u8], timeout: Duration, ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn send_parts<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, cmd: CMD, version: u8, body: &'life2 [&'life3 [u8]], ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn send_parts_with_resp<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, cmd: CMD, version: u8, body: &'life2 [&'life3 [u8]], timeout: Duration, ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn send_cmd<'life0, 'life1, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, cmd: CMD, version: u8, body: CmdBody, ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn send_cmd_with_resp<'life0, 'life1, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, cmd: CMD, version: u8, body: CmdBody, timeout: Duration, ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn send_by_specify_tunnel<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, tunnel_id: TunnelId, cmd: CMD, version: u8, body: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn send_by_specify_tunnel_with_resp<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, tunnel_id: TunnelId, cmd: CMD, version: u8, body: &'life2 [u8], timeout: Duration, ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn send_parts_by_specify_tunnel<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, tunnel_id: TunnelId, cmd: CMD, version: u8, body: &'life2 [&'life3 [u8]], ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn send_parts_by_specify_tunnel_with_resp<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, tunnel_id: TunnelId, cmd: CMD, version: u8, body: &'life2 [&'life3 [u8]], timeout: Duration, ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn send_cmd_by_specify_tunnel<'life0, 'life1, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, tunnel_id: TunnelId, cmd: CMD, version: u8, body: CmdBody, ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn send_cmd_by_specify_tunnel_with_resp<'life0, 'life1, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, tunnel_id: TunnelId, cmd: CMD, version: u8, body: CmdBody, timeout: Duration, ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn clear_all_tunnel<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_send<'life0, 'life1, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, tunnel_id: TunnelId, ) -> Pin<Box<dyn Future<Output = CmdResult<G>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Provided Methods

fn send2<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, cmd: CMD, version: u8, body: &'life2 [&'life3 [u8]], ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

👎Deprecated:

use send_parts instead

fn send2_with_resp<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, cmd: CMD, version: u8, body: &'life2 [&'life3 [u8]], timeout: Duration, ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

👎Deprecated:

use send_parts_with_resp instead

fn send2_by_specify_tunnel<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, tunnel_id: TunnelId, cmd: CMD, version: u8, body: &'life2 [&'life3 [u8]], ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

👎Deprecated:

use send_parts_by_specify_tunnel instead

fn send2_by_specify_tunnel_with_resp<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, tunnel_id: TunnelId, cmd: CMD, version: u8, body: &'life2 [&'life3 [u8]], timeout: Duration, ) -> Pin<Box<dyn Future<Output = CmdResult<CmdBody>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

👎Deprecated:

use send_parts_by_specify_tunnel_with_resp instead

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<C: WorkerClassification, M: CmdTunnelMeta, R: ClassifiedCmdTunnelRead<C, M>, W: ClassifiedCmdTunnelWrite<C, M>, F: ClassifiedCmdNodeTunnelFactory<C, M, R, W>, LEN: RawEncode + for<'a> RawDecode<'a> + Copy + Send + Sync + 'static + FromPrimitive + ToPrimitive + RawFixedBytes, CMD: RawEncode + for<'a> RawDecode<'a> + Copy + Send + Sync + 'static + RawFixedBytes + Eq + Hash + Debug, LISTENER: CmdTunnelListener<M, R, W>> CmdNode<LEN, CMD, M, ClassifiedCmdSend<C, M, R, W, LEN, CMD>, TrackedSendGuard<CmdNodeTunnelClassification<C>, M, ClassifiedCmdSend<C, M, R, W, LEN, CMD>, ClassifiedCmdNodeWriteFactory<C, M, R, W, F, LEN, CMD, LISTENER>>> for DefaultClassifiedCmdNode<C, M, R, W, F, LEN, CMD, LISTENER>

impl<M: CmdTunnelMeta, R: CmdTunnelRead<M>, W: CmdTunnelWrite<M>, F: CmdNodeTunnelFactory<M, R, W>, LEN: RawEncode + for<'a> RawDecode<'a> + Copy + RawFixedBytes + Sync + Send + 'static + FromPrimitive + ToPrimitive, CMD: RawEncode + for<'a> RawDecode<'a> + Copy + RawFixedBytes + Sync + Send + 'static + Eq + Hash + Debug, LISTENER: CmdTunnelListener<M, R, W>> CmdNode<LEN, CMD, M, CommonCmdSend<M, R, W, LEN, CMD>, TrackedSendGuard<(PeerId, Option<TunnelId>), M, CommonCmdSend<M, R, W, LEN, CMD>, CmdNodeWriteFactory<M, R, W, F, LEN, CMD, LISTENER>>> for DefaultCmdNode<M, R, W, F, LEN, CMD, LISTENER>