rsiot-extra-components

Утилиты для работы очереди сообщений

component_cache

Сохранение сообщений в кеше. Входящие сообщения могут сразу пересылаться на выход.

component_combine_message

Сборка нескольких сообщений в одно

component_delay

Перенаправление сообщений с задержкой. Поступающие сообщения сохраняются в кеше, периодически значения из кеша пересылаются на выход.

Пример использования:

• источник генерирует сообщения быстрее, чем потребитель может обработать

• для одновременного обновления данных в интерфейсе пользователя

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