rsiot

Module executor

Source
Expand description

Исполнитель - структура для запуска компонентов

§Пример с WASM и cmp_leptos

use std::time::Duration;

use leptos::{
    prelude::*,
    task::{spawn_local, Executor},
};
use reactive_stores::Store;
use tokio::task::LocalSet;

use crate::{
    components::cmp_leptos,
    executor::{ComponentExecutor, ComponentExecutorConfig},
    logging::configure_logging,
    message::{example_message::*, example_service::Service},
};

#[test]
#[allow(dead_code)]
fn test_wasm() {
    fn main() -> anyhow::Result<()> {
        #[component]
        fn App() -> impl IntoView {}

        configure_logging("info").unwrap();

        #[derive(Default, Clone, Store)]
        struct GlobalStore {}

        impl cmp_leptos::StoreBound for GlobalStore {}

        // cmp_leptos ------------------------------------------------------------------------------
        let config_leptos = cmp_leptos::Config {
            body_component: || view! { <App/> },
            input_store: GlobalStore::default(),
            output_store: GlobalStore::default(),
            fn_input: |_, _| (),
            fn_output: |_, _| (),
        };

        // config_executor -------------------------------------------------------------------------
        let config_executor = ComponentExecutorConfig {
            buffer_size: 100,
            service: Service::example_service,
            fn_auth: |msg, _| Some(msg),
            delay_publish: Duration::from_millis(100),
        };

        // executor --------------------------------------------------------------------------------
        Executor::init_wasm_bindgen().expect("executor should only be initialized once");

        let context = LocalSet::new();
        context.spawn_local(async move {
            ComponentExecutor::<Custom, Service>::new(config_executor)
                .add_cmp(cmp_leptos::Cmp::new(config_leptos))
                .wait_result()
                .await?;
            Ok(()) as anyhow::Result<()>
        });
        spawn_local(context);
        Ok(())
    }
}

Structs§

  • Cache
    Кеш сообщений
  • CmpInOut
    Подключение компонента к внутренней шине сообщений исполнителя
  • Component
    Представление обобщенного компонента
  • ComponentExecutor
    Запуск коллекции компонентов в работу
  • ComponentExecutorConfig
    Настройка исполнителя

Enums§

  • ComponentError
    Ошибки исполненителя компонентов

Traits§

Functions§

  • join_set_spawn
    Добавить задачу в множество задач (многопоточная версия)
  • sleep
    Waits until duration has elapsed.

Type Aliases§

  • CmpResult
    Тип возвращаемого значения функции process компонента