Prowl Queue

Some common logic around Tokio mpsc with retries for prowl notifications.

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

lib.rs:

Example

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