Struct CmpInOut

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

Fields

cache: Cache<TMsg>

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

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>

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

Trait Implementations

impl<TMsg> Clone for CmpInOut<TMsg>

where TMsg: Clone,

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> Debug for CmpInOut<TMsg>

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

Formats the value using the given formatter.