Lib.rs

消息队列工作实用工具

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