1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use tokio::task::JoinHandle;

use crate::types::{Input, Output};

/// Трейт для работы с компонентом из построителя цепочки компонентов
/// ComponentChainBuilder
pub trait IComponent<TMessage> {
    /// Задать входной поток
    fn set_input(&mut self, input: Input<TMessage>);

    /// Задать выходной поток
    fn set_output(&mut self, output: Output<TMessage>);

    /// Порождаем асинхронную задачу
    fn spawn(&mut self) -> JoinHandle<()>;

    /// Задать входной и выходной потоки и запустить на выполнение
    fn set_and_spawn(
        &mut self,
        input: Input<TMessage>,
        output: Output<TMessage>,
    ) -> JoinHandle<()> {
        self.set_input(input);
        self.set_output(output);
        self.spawn()
    }
}