Trait rsiot_component_core::IComponentFunction

pub trait IComponentFunction<TMessage, TConfig>: Send {
    // Required method
    fn call(
        &self,
        stream_input: Input<TMessage>,
        stream_output: Output<TMessage>,
        config: TConfig
    ) -> BoxFuture<'static, ()>;
}

Трейт для функции компонента

Required Methods

fn call( &self, stream_input: Input<TMessage>, stream_output: Output<TMessage>, config: TConfig ) -> BoxFuture<'static, ()>

Implementors

impl<T, F, TMessage, TConfig> IComponentFunction<TMessage, TConfig> for T

where T: Fn(Input<TMessage>, Output<TMessage>, TConfig) -> F + Send, F: Future<Output = ()> + 'static + Send,