Struct rsiot_component_core::Component

pub struct Component<TMessage, TConfig> {
    pub input: Option<ComponentInput<TMessage>>,
    pub output: Option<ComponentOutput<TMessage>>,
    pub config: Option<TConfig>,
    pub function: Box<dyn IComponentFunction<TMessage, TConfig>>,
    /* private fields */
}

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

Fields

input: Option<ComponentInput<TMessage>>

output: Option<ComponentOutput<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: ComponentInput<TMessage>)

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

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

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

fn set_cache(&mut self, cache: CacheType<TMessage>)

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

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

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

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