#в #сообщений #для #на #сообщения #кеше #выход

rsiot-channel-utils

Вспомогательные компоненты

1 unstable release

0.0.2 Nov 14, 2023

#7 in #на

MIT license

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