Struct rsiot_component_core::ComponentChain

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

Объединение компонентов в одну цепочку

TODO - добавить проверку конфигурации при вызовах split(), branch() …

Пример

//! Собрать такую цепочку:
//! 0 -> 1 -> 2 -> 3 ---> 9 -> 10
//!        -> 4 -> 5 --->
//!        -> 6 -> 7 -> 8
//!

use rsiot_component_core::{component_example, ComponentChain};
use rsiot_messages_core::IMessage;
use serde::{Deserialize, Serialize};

#[derive(Clone, Debug, Deserialize, Serialize)]
enum TestMessage {}

impl IMessage for TestMessage {}

fn main() {
    let _chain = ComponentChain::<TestMessage>::new(100)
        .add_cmp(component_example::new())
        .add_cmp(component_example::new())
        .split()
        .add_cmp(component_example::new())
        .add_cmp(component_example::new())
        .branch()
        .add_cmp(component_example::new())
        .add_cmp(component_example::new())
        .branch()
        .add_cmp(component_example::new())
        .add_cmp(component_example::new())
        .add_cmp(component_example::new())
        .join()
        .add_cmp(component_example::new())
        .add_cmp(component_example::new());
}

Implementations

impl<TMessage> ComponentChain<TMessage>where TMessage: IMessage + 'static,

pub fn new(buffer: usize) -> Self

Создание цепочки

pub fn add_cmp(self, component: Box<dyn IComponent<TMessage>>) -> Self

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

pub fn split(self) -> Self

Разделить на параллельные пути

pub fn branch(self) -> Self

Закончился параллельный путь

pub fn join(self) -> Self

Объединить параллельные пути

pub async fn spawn(&mut self)

Запустить на выполнение все компоненты. Поток ожидает выполения всех задач