Struct CmpInOut

pub struct CmpInOut<TMsg>
where
    TMsg: MsgDataBound,
{
    pub cache: Cache<TMsg>,
    /* private fields */
}

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

Fields

cache: Cache<TMsg>

Ссылка на кэш TODO - проверить, скорее всего можно сделать приватным

Implementations

impl<TMsg> CmpInOut<TMsg>

where TMsg: MsgDataBound,

pub fn new( input: Receiver<Message<TMsg>>, output: Sender<Message<TMsg>>, cache: Cache<TMsg>, name: &str, id: Uuid, auth_perm: AuthPermissions, fn_auth: fn(Message<TMsg>, &AuthPermissions) -> Option<Message<TMsg>>, ) -> Self

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

pub fn clone_with_new_id(&self, name: &str, auth_perm: AuthPermissions) -> Self

Клонировать и присвоить новый идентификатор

Необходимо вызывать в начале исполнения компонента, чтобы у каждого компонента был уникальный id

pub async fn recv_input(&mut self) -> Result<Message<TMsg>, ComponentError>

Получение сообщений со входа

pub async fn recv_cache_all(&self) -> Vec<Message<TMsg>>

Возвращает копию сообщений из кеша

pub async fn recv_cache_msg(&self, key: &str) -> Option<Message<TMsg>>

Возвращает сообщение из кеша по ключу

pub async fn send_output( &self, msg: Message<TMsg>, ) -> Result<(), ComponentError>

Отправка сообщений на выход

pub fn send_output_blocking( &self, msg: Message<TMsg>, ) -> Result<(), ComponentError>

Отправка исходящих сообщений, в синхронном окружении

pub fn max_capacity(&self) -> usize

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

Trait Implementations

impl<TMsg> Clone for CmpInOut<TMsg>

where TMsg: MsgDataBound,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<TMsg> Debug for CmpInOut<TMsg>

where TMsg: MsgDataBound + Debug,

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

Formats the value using the given formatter.