pub struct FnProcessMaster<'a, TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress>where
TMsg: MsgDataBound + 'static,
TService: ServiceBound + 'static,
TError: Send + Sync + 'static,
TAddress: AddressBound,{
pub msg_bus: CmpInOut<TMsg, TService>,
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 devices: Vec<Box<dyn DeviceTrait<TMsg, TFieldbusRequest, TFieldbusResponse, TAddress>>>,
}
Expand description
Запуск задач, общих для всех компонентов, выполняющих опрос устройств по шине
Fields§
§msg_bus: CmpInOut<TMsg, TService>
Шина сообщений
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
devices: Vec<Box<dyn DeviceTrait<TMsg, TFieldbusRequest, TFieldbusResponse, TAddress>>>
Массив устройств
Implementations§
Source§impl<TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress> FnProcessMaster<'_, TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress>where
TMsg: MsgDataBound + 'static,
TService: ServiceBound + 'static,
TError: Send + Sync + 'static,
TFieldbusRequest: RequestResponseBound<TAddress> + 'static,
TFieldbusResponse: RequestResponseBound<TAddress> + 'static,
TAddress: 'static + AddressBound,
impl<TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress> FnProcessMaster<'_, TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress>where
TMsg: MsgDataBound + 'static,
TService: ServiceBound + 'static,
TError: Send + Sync + 'static,
TFieldbusRequest: RequestResponseBound<TAddress> + 'static,
TFieldbusResponse: RequestResponseBound<TAddress> + 'static,
TAddress: 'static + AddressBound,
Auto Trait Implementations§
impl<'a, TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress> Freeze for FnProcessMaster<'a, TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress>where
TService: Freeze,
impl<'a, TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress> !RefUnwindSafe for FnProcessMaster<'a, TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress>
impl<'a, TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress> Send for FnProcessMaster<'a, TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress>
impl<'a, TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress> Sync for FnProcessMaster<'a, TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress>
impl<'a, TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress> Unpin for FnProcessMaster<'a, TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress>where
TService: Unpin,
impl<'a, TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress> !UnwindSafe for FnProcessMaster<'a, TMsg, TService, TError, TFieldbusRequest, TFieldbusResponse, TAddress>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more