1 unstable release
0.0.2 | Nov 14, 2023 |
---|
#7 in #на
14KB
269 lines
Утилиты для работы очереди сообщений
component_cache
Сохранение сообщений в кеше. Входящие сообщения могут сразу пересылаться на выход.
component_combine_message
Сборка нескольких сообщений в одно
component_delay
Перенаправление сообщений с задержкой. Поступающие сообщения сохраняются в кеше, периодически значения из кеша пересылаются на выход.
Пример использования:
-
источник генерирует сообщения быстрее, чем потребитель может обработать
-
для одновременного обновления данных в интерфейсе пользователя
component_filter
Фильтрация сообщений
component_mpsc_to_broadcast
Преобразование mpsc::Receiver в broadcast::Sender
component_mpsc_to_many_mpsc
Преобразование одного mpsc::Receiver в несколько mpsc::Sender
Dependencies
~3–10MB
~95K SLoC