Утилиты для работы очереди сообщений ## component_cache Сохранение сообщений в кеше. Входящие сообщения могут сразу пересылаться на выход. ![](../doc/component-cache.svg) ## component_combine_message Сборка нескольких сообщений в одно ## component_delay Перенаправление сообщений с задержкой. Поступающие сообщения сохраняются в кеше, периодически значения из кеша пересылаются на выход. ![](../doc/component-delay.svg) Пример использования: - источник генерирует сообщения быстрее, чем потребитель может обработать - для одновременного обновления данных в интерфейсе пользователя ## component_filter Фильтрация сообщений ## component_inject_periodic Периодическое генерирование сообщений ## component_logger Логгирование входящих сообщений; пересылка на выходной поток, если задан. ## component_many_mpsc_to_mpsc Объединение нескольких потоков в один поток ## component_mpsc_to_broadcast Преобразование mpsc::Receiver в broadcast::Sender ## component_mpsc_to_many_mpsc Преобразование одного mpsc::Receiver в несколько mpsc::Sender