Skip to main content

worker/
worker.rs

1use que_luyo::BiteQueue;
2
3fn main() -> Result<(), Box<dyn std::error::Error>> {
4    let mut queue = BiteQueue::from_iter(["task-1", "task-2", "task-3"]);
5
6    let completed = queue.bite(2)?.commit();
7    println!("completed: {completed:?}");
8
9    {
10        let retry = queue.bite(1)?;
11        println!("will retry: {:?}", retry.front());
12    }
13
14    println!("remaining: {:?}", queue.iter().collect::<Vec<_>>());
15    Ok(())
16}