Struct 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()]);
}

Implementations

impl<TMessage> ComponentCollection<TMessage>

where TMessage: IMessage + 'static,

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

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

pub async fn spawn(&mut self)

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