Struct rsiot_component_core::ComponentCollection

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

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

Пример

use rsiot_component_core::{component_example, ComponentCollection};
use rsiot_messages_core::ExampleMessage;

fn main() {
    let _chain = ComponentCollection::<ExampleMessage>::new(
        100,
        vec![component_example::new(component_example::Config {})],
    );
}

Implementations

impl<TMessage> ComponentCollection<TMessage>

where TMessage: IMessage + 'static,

pub fn new( buffer_size: usize, components: Vec<Box<dyn IComponent<TMessage>>> ) -> Self

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

pub async fn spawn(&mut self)

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