Lib.rs

消息队列工作工具

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