What's Changed
- Breaking: Queues are now stored and passed as
Arc<Queue<_>>;
Worker::newandScheduler::newtakeArc<Queue<_>>instead ofQueue<_>. #100 - Breaking:
Job::run_workerandJob::run_schedulerhave been removed. #100 - Breaking:
Job::runandJob::startnow take&selfrather than consumingself. #100 - Fix: Shutdown channels are now unique. #97
- Add:
Job::queue,Job::worker, andJob::schedulerhelpers for
zero‑boilerplate executor creation. #100 - Add:
enqueue_multiet al, allowing batched enqueue. #79
Migration to 0.2.0:
- Before:
let queue = Queue::builder().build().await?;
let job = Job::builder().queue(queue.clone()).build();
Worker::new(queue.clone(), job.clone()).run().await;- After:
let job = Job::builder().pool(pool).build().await?;
job.worker().run().await;New Contributors
- @kirillsalykin made their first contribution in #79
- @victoronascimento made their first contribution in #95
Full Changelog: v0.1.2...v0.2.0