#pubsub #mpsc #channel #dashmap

simple_pubsub

简单 Pubsub 使用 dashmap 和 mpsc 通道

2 个版本

0.5.3 2022年2月13日
0.5.2 2022年1月22日
0.5.1 2022年1月22日
0.5.0 2022年1月22日

开发工具 中排名第 1773

MIT 许可证

9KB
155

简单 Pubsub

使用方法

let topic = "lobby";
let broadcaster: Arc<Broadcaster<String>> = Arc::new(Broadcaster::default());
let (id, mut receiver) = broadcaster.clone().subscribe(topic);
broadcaster.publish(topic, Arc::new("hello world".into()));
let data = receiver.recv().await.unwrap();
assert!(id > 0);
assert_eq!(data.as_ref(), "hello world");

依赖关系

~3–10MB
~72K SLoC