Struct rsiot_component_core::ComponentExecutor

pub struct ComponentExecutor<TMessage>
where
    TMessage: IMessage,
{ /* private fields */ }

Запуск коллекции компонентов в работу

Примеры

Многопоточное окружение

TODO

Однопоточное окружение

TODO

Однопоточное окружение - WASM (Leptos)

use leptos::*;

let context = LocalSet::new();
context.spawn_local(async move {
    ComponentExecutor::<Message>::new(100)
        .add_cmp(cmp_websocket_client_wasm::Cmp::new(ws_client_config))
        .add_cmp(cmp_leptos::Cmp::new(leptos_config))
        .wait_result()
        .await?;
    Ok(()) as anyhow::Result<()>
});
spawn_local(context);
Ok(())

Implementations

impl<TMessage> ComponentExecutor<TMessage>

where TMessage: IMessage + 'static,

pub fn new(buffer_size: usize) -> Self

Создание коллекции компонентов

pub fn add_cmp( self, component: impl IComponent<TMessage> + Send + 'static ) -> Self

where TMessage: IMessage,

Добавить компонент

pub async fn wait_result(&mut self) -> Result<(), ComponentError>

Запустить на выполнение все компоненты.

Компоненты не должны заканчивать выполнение. Если хоть один остановился (неважно по какой причине - по ошибке или нет), это ошибка выполнения.