Struct FieldbusExecution 

pub struct FieldbusExecution<'a, TMsg, TError, TFieldbusRequest, TFieldbusResponse>
where
    TMsg: MsgDataBound + 'static,
    TError: Send + Sync + 'static,
{
    pub msgbus_linker: MsgBusLinker<TMsg>,
    pub task_set: &'a mut JoinSet<Result<(), 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

msgbus_linker: MsgBusLinker<TMsg>

Подключение к шине MsgBus

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

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

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> FieldbusExecution<'_, 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>>)

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

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