xq-notification-rs
rust 通知封装
使用介绍
Cargo.toml
serde_json = "^1.0"
xq_notification = "*"
示例代码
use ;
use NotificationManager;
use serde_json;
rust 通知封装
Cargo.toml
serde_json = "^1.0"
xq_notification = "*"
示例代码
use std::{thread};
use xq_notification::notification::NotificationManager;
use serde_json;
fn main() {
// 第一个通知
thread::spawn(move || match NotificationManager::observe("test") {
Some(r) => loop {
match r.recv() {
Ok(_) => {
// 接收到通知
}
Err(_) => {
break;
}
}
},
None => {}
});
// 第二个通知
thread::spawn(move || match NotificationManager::observe("test") {
Some(r) => loop {
match r.recv() {
Ok(_) => {
// 接收到通知
}
Err(_) => {
break;
}
}
},
None => {}
});
// 发送通知
for i in 0..10000 {
NotificationManager::publish("test", serde_json::Value::String(format!("{}", i)));
}
}