Struct Config

pub struct Config<TMsg>
where
    TMsg: MsgDataBound,
{
    pub fn_process: Box<dyn Fn(CmpInOut<TMsg>) -> LocalBoxFuture<'static, CmpResult>>,
}

Настройки cmp_external_fn_process

Fields

fn_process: Box<dyn Fn(CmpInOut<TMsg>) -> LocalBoxFuture<'static, CmpResult>>

Внешняя функция для выполнения

Выполняемую асинхронную функцию fn_external необходимо обернуть в функцию.

Пример

use std::time::Duration;

use futures::future::LocalBoxFuture;
use tokio::time::sleep;
use tracing::info;

use rsiot::{
    components::cmp_external_fn_process,
    executor::{CmpInOut, ComponentResult},
    message::{example_message::*, *},
};

fn fn_process_wrapper<TMsg>(
    in_out: CmpInOut<TMsg>,
) -> LocalBoxFuture<'static, ComponentResult>
where
    TMsg: MsgDataBound + 'static,
{
    Box::pin(async { fn_process(in_out).await })
}
async fn fn_process<TMsg>(_in_out: CmpInOut<TMsg>) -> ComponentResult {
    loop {
        info!("External fn process");
        sleep(Duration::from_secs(2)).await;
    }
}

let _config = cmp_external_fn_process::Config {
    fn_process: Box::new(fn_process_wrapper::<Custom>),
};

Trait Implementations

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

where TMsg: MsgDataBound,

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

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

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