Function rsiot_extra_components::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>