Struct Config

pub struct Config<TMsg, TStorageData>
where
    TMsg: MsgDataBound,
    TStorageData: Debug + Default + DeserializeOwned + PartialEq + Serialize,
{
    pub fn_input: fn(_: &TStorageData, _: &Message<TMsg>) -> Option<TStorageData>,
    pub fn_output: fn(_: &TStorageData) -> Vec<Message<TMsg>>,
}

Конфигурация cmp_storage_esp

Fields

fn_input: fn(_: &TStorageData, _: &Message<TMsg>) -> Option<TStorageData>

Функция для сохранения информации из входных сообщений в памяти ESP.

Примеры

use rsiot::message::{example_message::*, *};
use serde::Deserialize;

#[derive(Debug, Default, Deserialize, PartialEq, Serialize)]
struct StorageData {
    pub test_f64: f64,
    pub test_i32: i32,
}

let _ = Config {
    fn_input: |data: &StorageData, msg: &Message<Custom>| match msg.data {
        MsgData::Custom(Custom::ValueInstantF64(value)) => Some(StorageData {
            test_f64: value,
            ..*data
        }),
        _ => None,
    },
    fn_output: |_| vec![],
};

fn_output: fn(_: &TStorageData) -> Vec<Message<TMsg>>

Функция для выдачи сообщений из сохраненных данных.

Вызывается один раз, при запуске ESP.

Примеры

use rsiot::message::{example_message::*, *};
use serde::{Deserialize, Serialize};

#[derive(Debug, Default, Deserialize, PartialEq, Serialize)]
struct StorageData {
    pub test_f64: f64,
    pub test_i32: i32,
}

let _ = Config {
    fn_input: |_, _| None,
    fn_output: |data: &StorageData| {
        vec![Message::new(MsgData::Custom(Custom::ValueInstantF64(
            data.test_f64,
        )))]
    },
};

Trait Implementations

impl<TMsg, TStorageData> Debug for Config<TMsg, TStorageData>

where TMsg: MsgDataBound + Debug, TStorageData: Debug + Default + DeserializeOwned + PartialEq + Serialize + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<TMsg, TService, TStorageData> IComponentProcess<Config<TMsg, TStorageData>, TMsg, TService> for Component<Config<TMsg, TStorageData>, TMsg, TService>

where TMsg: MsgDataBound + 'static, TService: ServiceBound + 'static, TStorageData: Debug + Default + DeserializeOwned + PartialEq + Serialize + 'static,

fn process<'life0, 'async_trait>( &'life0 self, config: Config<TMsg, TStorageData>, in_out: CmpInOut<TMsg, TService>, ) -> Pin<Box<dyn Future<Output = Result<(), ComponentError>> + 'async_trait>>

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

Основная функция компонента