Struct FnProcessMaster

pub struct FnProcessMaster<'a, TMsg, TError, TFieldbusRequest, TFieldbusResponse>
where
    TMsg: MsgDataBound + 'static,
    TError: Send + Sync + 'static,
{
    pub msg_bus: CmpInOut<TMsg>,
    pub buffer_size: usize,
    pub task_set: &'a mut JoinSet<Result<(), TError>>,
    pub error_msgbus_to_broadcast: fn(Error) -> TError,
    pub error_filter: fn(Error) -> TError,
    pub error_mpsc_to_msgbus: fn(Error) -> TError,
    pub error_master_device: fn(Error) -> TError,
    pub error_tokiompscsend: fn() -> TError,
    pub devices: Vec<Box<dyn DeviceTrait<TMsg, TFieldbusRequest, TFieldbusResponse>>>,
}

Запуск задач, общих для всех компонентов, выполняющих опрос устройств по шине

Fields

msg_bus: CmpInOut<TMsg>

Шина сообщений

buffer_size: usize

Ёмкость очередей сообщений между задачами

task_set: &'a mut JoinSet<Result<(), TError>>

Ссылка на коллекцию задач tokio

error_msgbus_to_broadcast: fn(Error) -> TError

Ошибка msgbus_to_broadcast

error_filter: fn(Error) -> TError

Ошибка filter_identical_data

error_mpsc_to_msgbus: fn(Error) -> TError

Ошибка mpsc_to_msgbus

error_master_device: fn(Error) -> TError

Ошибка master_device

error_tokiompscsend: fn() -> TError

Ошибка tokio::mpsc::send

devices: Vec<Box<dyn DeviceTrait<TMsg, TFieldbusRequest, TFieldbusResponse>>>

Массив устройств

Implementations

impl<TMsg, TError, TFieldbusRequest, TFieldbusResponse> FnProcessMaster<'_, TMsg, TError, TFieldbusRequest, TFieldbusResponse>

where TMsg: MsgDataBound + 'static, TError: Send + Sync + 'static, TFieldbusRequest: RequestResponseBound + 'static, TFieldbusResponse: RequestResponseBound + 'static,

pub fn spawn( self, ) -> (Receiver<FieldbusRequestWithIndex<TFieldbusRequest>>, Sender<FieldbusResponseWithIndex<TFieldbusResponse>>)

Запуск задач.

Возвращает кортеж с каналами передачи запросов / ответов