component_filter_message

rsiot_channel_utils

Function component_filter_message 

Source 
pub async fn component_filter_message<TMessage>(
    input: Receiver<TMessage>,
    output: Sender<TMessage>,
    filter_fn: fn(TMessage) -> Option<TMessage>,
)
Expand description

Компонент для фильтрации сообщений

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