Struct ComponentExecutorConfig

pub struct ComponentExecutorConfig<TMsg> {
    pub buffer_size: usize,
    pub fn_auth: fn(_: Message<TMsg>, _: &AuthPermissions) -> Option<Message<TMsg>>,
    pub delay_publish: Duration,
}

Настройка исполнителя

Fields

buffer_size: usize

Размер буфера канала сообщения

fn_auth: fn(_: Message<TMsg>, _: &AuthPermissions) -> Option<Message<TMsg>>

Функция фильтрации сообщений в зависимости от текущей авторизации

Примеры

• Все сообщения блокируются

|_, _| None

• Все сообщения разрешены

|msg, _| Some(msg)

delay_publish: Duration

Задержка публикации сообщений

Рассылка сообщений осуществляется по каналу broadcast. При инициализации компоненты получают только новые сообщения. Эта задержка нужна для того, чтобы компоненты успели запуститься.