prowl_queue/
lib.rs

1//! ## Example
2//! ```
3//! use prowl_queue::{ProwlQueue, ProwlQueueSender};
4//!
5//! fn application(sender: &ProwlQueueSender) {
6//!     let notification = prowl::Notification::new(...)
7//!     sender.add(notification).expect("Failed to add notification");
8//! }
9//!
10//! #[tokio::main]
11//! async fn main() {
12//!     let (sender, reciever) = ProwlQueue::default().into_parts();
13//!     tokio::spawn(reciever.async_loop());
14//!     application(&sender);
15//! }
16//! ```
17
18mod options;
19mod queue;
20
21pub use options::{LinearRetry, ProwlQueueOptions, RetryMethod};
22pub use queue::{AddError, ProwlQueue, ProwlQueueReceiver, ProwlQueueSender};