rsiot/executor/
types.rs

1use tokio::sync::{broadcast, mpsc};
2
3use crate::message::*;
4
5use super::ComponentError;
6
7/// Тип возвращаемого значения функции `process` компонента
8pub type CmpResult = Result<(), ComponentError>;
9pub(crate) type CmpInput<TMsg> = broadcast::Receiver<Message<TMsg>>;
10pub(crate) type CmpOutput<TMsg> = mpsc::Sender<Message<TMsg>>;
11
12/// Функция фильтрации сообщений в зависимости от авторизации
13pub(crate) type FnAuth<TMsg> = fn(Message<TMsg>, &AuthPermissions) -> Option<Message<TMsg>>;