Crates.io | rsiot-extra-components |
lib.rs | rsiot-extra-components |
version | 0.0.71 |
source | src |
created_at | 2023-11-20 13:25:57.062246 |
updated_at | 2024-03-07 08:31:39.593817 |
description | Дополнительные компоненты |
homepage | |
repository | |
max_upload_size | |
id | 1042147 |
size | 63,176 |
Утилиты для работы очереди сообщений
Сохранение сообщений в кеше. Входящие сообщения могут сразу пересылаться на выход.
Сборка нескольких сообщений в одно
Перенаправление сообщений с задержкой. Поступающие сообщения сохраняются в кеше, периодически значения из кеша пересылаются на выход.
Пример использования:
источник генерирует сообщения быстрее, чем потребитель может обработать
для одновременного обновления данных в интерфейсе пользователя
Фильтрация сообщений
Периодическое генерирование сообщений
Логгирование входящих сообщений; пересылка на выходной поток, если задан.
Объединение нескольких потоков в один поток
Преобразование mpsc::Receiver в broadcast::Sender
Преобразование одного mpsc::Receiver в несколько mpsc::Sender