async_queue

Releases

1. ▸▾3.0.05 Apr 20262 sources agree

   `addJob` now returns a `Future` — await the result of any individual job without relying on listeners. Works alongside previousResult without conflict

   New Features

   • addJob now returns a Future — await the result of any individual job without relying on listeners. Works alongside previousResult without conflict.
   • Automatic retry on job exceptions — jobs that throw are automatically retried up to retryTime times. Manual retry() still works for custom logic.
   • onError callback — dedicated error handler on AsyncQueue and AsyncQueue.autoStart constructors, called with (error, jobLabel) on each failure.
   • Priority queue — addJob accepts a priority parameter (default 0). Higher priority jobs are placed closer to the front. Same-priority jobs maintain FIFO order.
   • Pause / Resume — pause() halts processing after the current job finishes without losing queued jobs. resume() continues. Adds isPaused getter and queuePaused/queueResumed events.
   • Retry with delay — addJob accepts a retryDelay Duration to wait between retry attempts. Works with both auto-retry and manual retry().
   • Job timeout — addJob accepts a timeout Duration. Jobs exceeding the timeout throw TimeoutException, triggering auto-retry like any other exception.
   • isRunning getter — exposes queue running state.
   • add QueueEventType.jobError, QueueEventType.queuePaused, QueueEventType.queueResumed events

   Bug Fixes

   • fix post-increment bug in duplicate label tracking (value was never actually incremented)
   • fix null crash when retry() is called on an empty queue
   • fix _previousResult leaking across separate start() runs
   • fix addJobThrow label parameter type from String? to Object? to match addJob
   • fix _isForcedStop flag now properly cleared after start() loop exits instead of immediately in stop()
   • fix failed nodes after auto-retry limit never being removed from queue (caused infinite loop)

   Code Cleanup

   • sync AsyncQueueInterface signatures with actual implementation
   • remove dead commented-out code (list(), getJobInfo()) from source and interface
   • remove unused imports and stray print() calls from tests

   Tests

   • add test coverage for addJob returning Future (result, chaining, autoStart, previousResult, closed queue)
   • add test coverage for AsyncQueue.autoStart() (execution order, late adds, events, stop)
   • add tests for onError callback, priority ordering, pause/resume, retry delay, and job timeout
   • add meaningful job label assertions in event tests
   • clean up async_queue_info_test.dart with actual assertions