Crate 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)));
    } 
}

Modules

notification