Trait rsiot_component_core::IComponent

pub trait IComponent<TMessage> {
    // Required methods
    fn set_input(&mut self, input: StreamInput<TMessage>);
    fn set_output(&mut self, output: StreamOutput<TMessage>);
    fn spawn(&mut self) -> JoinHandle<()>;

    // Provided method
    fn set_and_spawn(
        &mut self,
        input: StreamInput<TMessage>,
        output: StreamOutput<TMessage>
    ) -> JoinHandle<()> { ... }
}

Трейт для работы с компонентом из построителя цепочки компонентов ComponentChainBuilder

Required Methods

fn set_input(&mut self, input: StreamInput<TMessage>)

Задать входной поток

fn set_output(&mut self, output: StreamOutput<TMessage>)

Задать выходной поток

fn spawn(&mut self) -> JoinHandle<()>

Порождаем асинхронную задачу

Provided Methods

fn set_and_spawn( &mut self, input: StreamInput<TMessage>, output: StreamOutput<TMessage> ) -> JoinHandle<()>

Задать входной и выходной потоки и запустить на выполнение

Implementors

impl<TMessage, TConfig> IComponent<TMessage> for Component<TMessage, TConfig>where TConfig: Clone,