Struct MsgBusLinker 

pub struct MsgBusLinker<TMsg>
where
    TMsg: MsgDataBound,
{ /* private fields */ }

Подключение компонента к внутренней шине сообщений исполнителя

Implementations

impl<TMsg> MsgBusLinker<TMsg>

where TMsg: MsgDataBound,

pub fn new( input: Receiver<Message<TMsg>>, output: Sender<Message<TMsg>>, auth_perm: AuthPermissions, fn_auth: fn(Message<TMsg>, &AuthPermissions) -> Option<Message<TMsg>>, ) -> Self

Создание подключения к внутренней шине сообщений исполнителя

pub fn init(self, name: &str) -> Self

Инициализация шины сообщений с новым идентификатором и именем

pub fn input(&self) -> MsgBusInput<TMsg>

Канал входящих сообщений

pub fn output(&self) -> MsgBusOutput<TMsg>

Канал исходящих сообщений

pub fn input_output(&self) -> (MsgBusInput<TMsg>, MsgBusOutput<TMsg>)

Каналы входящих сообщений и исходящих сообщений

pub fn max_capacity(&self) -> usize

Возвращает максимальный размер очереди сообщений

pub fn close(self)

Закрыть подключение

Trait Implementations

impl<TMsg> Clone for MsgBusLinker<TMsg>

where TMsg: MsgDataBound,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<TMsg> Debug for MsgBusLinker<TMsg>

where TMsg: MsgDataBound + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.