component_combine_message

rsiot_channel_utils

Function component_combine_message 

Source 
pub async fn component_combine_message<TMessage>(
    input: Receiver<TMessage>,
    output: Sender<TMessage>,
    filter_fn: fn(TMessage) -> Option<TMessage>,
    combine_fn: fn(Vec<TMessage>) -> Option<TMessage>,
)
where
    TMessage: IMessage,
Expand description

Компонент для преобразования нескольких сообщений в новое. На выход передаются все исходные сообщения, плюс новые

  • input - исходный поток сообщений
  • output - исходный поток сообщений, плюс новые сообщения
  • filter_fn - функция для фильтрации необходимых исходных сообщений. Сообщения сохраняются в хеше. Сигнатура fn(TMessage) -> Option<TMessage>
  • transform_fn - функция для преобразования сохраненных сообщений в новое. Сигнатура fn(Vec<TMessage>) -> Option<TMessage>