Struct ComponentExecutor

pub struct ComponentExecutor<TMsg> { /* private fields */ }

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

Примеры

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

TODO

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

TODO

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

use leptos::*;

let context = LocalSet::new();
context.spawn_local(async move {
    ComponentExecutor::<Message>::new(100, "example")
        .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<TMsg> ComponentExecutor<TMsg>

where TMsg: MsgDataBound + 'static,

pub fn new(config: ComponentExecutorConfig<TMsg>) -> Self

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

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

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

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

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

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