pub async fn component_cache<TMessage>(
input: Receiver<TMessage>,
output: Option<Sender<TMessage>>,
cache: CacheType<TMessage>,
)where
TMessage: IMessage,Expand description
Компонент для сохранения сообщений в кеше. Сохраняется только последний вариант
Входящие сообщения пересылаются без изменений в исходящие
Кеш представляет собой HashMap, а точнее
Arc<Mutex<HashMap<String, TMessage>>>