Struct rsiot_component_core::Component

pub struct Component<TMessage, TConfig> {
    pub input: Option<Input<TMessage>>,
    pub output: Option<Output<TMessage>>,
    pub config: Option<TConfig>,
    pub function: Box<dyn IComponentFunction<TMessage, TConfig>>,
}

Обобщенный компонент

Fields

input: Option<Input<TMessage>>

output: Option<Output<TMessage>>

config: Option<TConfig>

function: Box<dyn IComponentFunction<TMessage, TConfig>>

Implementations

impl<TMessage, TConfig> Component<TMessage, TConfig>

pub fn new( config: TConfig, func: impl IComponentFunction<TMessage, TConfig> + 'static ) -> Self

Trait Implementations

impl<TMessage, TConfig> IComponent<TMessage> for Component<TMessage, TConfig>

fn set_input(&mut self, stream_input: Input<TMessage>)

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

fn set_output(&mut self, stream_output: Output<TMessage>)

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

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

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

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

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