2 个版本
0.5.3 | 2022年2月13日 |
---|---|
0.5.2 | 2022年1月22日 |
0.5.1 |
|
0.5.0 |
|
在 开发工具 中排名第 1773
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