Prowl Queue

关于 Tokio mpsc 和 Prowl 通知重试的一些常见逻辑。

https://docs.rs/prowl-queue/0.1.1/prowl_queue/

lib.rs:

示例

use prowl_queue::{ProwlQueue, ProwlQueueSender};

fn application(sender: &ProwlQueueSender) {
    let notification = prowl::Notification::new(...)
    sender.add(notification).expect("Failed to add notification");
}

#[tokio::main]
async fn main() {
    let (sender, reciever) = ProwlQueue::default().into_parts();
    tokio::spawn(reciever.async_loop());
    application(&sender);
}