Struct DefaultClassifiedCmdClient

pub struct DefaultClassifiedCmdClient<C: WorkerClassification, R: ClassifiedCmdTunnelRead<C>, W: ClassifiedCmdTunnelWrite<C>, F: ClassifiedCmdTunnelFactory<C, 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> { /* private fields */ }

Implementations

impl<C: WorkerClassification, R: ClassifiedCmdTunnelRead<C>, W: ClassifiedCmdTunnelWrite<C>, F: ClassifiedCmdTunnelFactory<C, 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> DefaultClassifiedCmdClient<C, R, W, F, LEN, CMD>

pub fn new(factory: F, tunnel_count: u16) -> Arc<Self>

Trait Implementations

impl<C: WorkerClassification, R: ClassifiedCmdTunnelRead<C>, W: ClassifiedCmdTunnelWrite<C>, F: ClassifiedCmdTunnelFactory<C, 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> ClassifiedCmdClient<LEN, CMD, C> for DefaultClassifiedCmdClient<C, R, W, F, LEN, CMD>

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

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

fn send2_by_classified_tunnel<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, classification: C, cmd: CMD, version: u8, body: &'life1 [&'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 find_tunnel_id_by_classified<'life0, 'async_trait>( &'life0 self, classification: C, ) -> Pin<Box<dyn Future<Output = CmdResult<TunnelId>> + Send + 'async_trait>>

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

impl<C: WorkerClassification, R: ClassifiedCmdTunnelRead<C>, W: ClassifiedCmdTunnelWrite<C>, F: ClassifiedCmdTunnelFactory<C, 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> CmdClient<LEN, CMD> for DefaultClassifiedCmdClient<C, R, W, F, LEN, CMD>

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

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

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

fn send2<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, cmd: CMD, version: u8, body: &'life1 [&'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<'life0, 'life1, 'async_trait>( &'life0 self, tunnel_id: TunnelId, cmd: CMD, version: u8, body: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = CmdResult<()>> + Send + 'async_trait>>

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

fn send2_by_specify_tunnel<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tunnel_id: TunnelId, cmd: CMD, version: u8, body: &'life1 [&'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 clear_all_tunnel<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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