Struct Config

pub struct Config<TMsg>
where
    TMsg: MsgDataBound,
{
    pub fn_generate_self_counter: fn(_: u8) -> Message<TMsg>,
    pub generate_self_period: Duration,
    pub fn_find_partner_counter: fn(_: &Message<TMsg>) -> Option<u8>,
    pub fn_check_partner_counter: fn(_: bool) -> Message<TMsg>,
    pub check_partner_period: Duration,
}

Конфигурация cmp_check_livecounter

Fields

fn_generate_self_counter: fn(_: u8) -> Message<TMsg>

Функция для формирования сообщения о собственном счетчике

generate_self_period: Duration

Период создания сообщения о собственном счетчике

fn_find_partner_counter: fn(_: &Message<TMsg>) -> Option<u8>

Ищем сообщения со значением счетчика

fn_check_partner_counter: fn(_: bool) -> Message<TMsg>

Функция для формирования сообщения о наличии связи. В функцию передается булевое значение, указывающее на наличие связи. true - есть связь, false - нет связи.

check_partner_period: Duration

Период проверки счетчика на наличие связи

Trait Implementations

impl<TMsg> Clone for Config<TMsg>

where TMsg: MsgDataBound + Clone,

fn clone(&self) -> Config<TMsg>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<TMsg, TService> IComponentProcess<Config<TMsg>, TMsg, TService> for Component<Config<TMsg>, TMsg, TService>

where TMsg: MsgDataBound + 'static, TService: 'static + ServiceBound,

fn process<'life0, 'async_trait>( &'life0 self, config: Config<TMsg>, msg_bus: CmpInOut<TMsg, TService>, ) -> Pin<Box<dyn Future<Output = CmpResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Основная функция компонента