rsiot/components/cmp_modbus_client/
component.rs

1use async_trait::async_trait;
2
3use crate::{
4    executor::{CmpInOut, Component, ComponentError, IComponentProcess},
5    message::{AuthPermissions, MsgDataBound},
6};
7
8use super::{config::Config, fn_process::fn_process};
9
10#[cfg_attr(not(feature = "single-thread"), async_trait)]
11#[cfg_attr(feature = "single-thread", async_trait(?Send))]
12impl<TMessage> IComponentProcess<Config<TMessage>, TMessage>
13    for Component<Config<TMessage>, TMessage>
14where
15    TMessage: MsgDataBound + 'static,
16{
17    async fn process(
18        &self,
19        config: Config<TMessage>,
20        in_out: CmpInOut<TMessage>,
21    ) -> Result<(), ComponentError> {
22        fn_process(
23            config,
24            in_out.clone_with_new_id("cmp_modbus_client", AuthPermissions::FullAccess),
25        )
26        .await?;
27        Ok(())
28    }
29}
30
31/// Компонент cmp_modbus_client
32pub type Cmp<TMessage> = Component<Config<TMessage>, TMessage>;