Skip to content

Commit

Permalink
Removing unused line
Browse files Browse the repository at this point in the history
  • Loading branch information
rishigupta1599 committed Nov 28, 2023
1 parent 9d48829 commit 25b5e72
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions packages/core/src/queue.js
Original file line number Diff line number Diff line change
Expand Up @@ -282,10 +282,6 @@ export class Queue {
let queued, pending = this.#pending.size;
// calculate the position within queued when not pending
if (task && task.pending == null) queued = positionOf(this.#queued, task);
// calculate the position within pending when not stopping
// Commenting below line reason being currently if the task passed is found we will stop flushing
// rest of the tasks but ideally it should wait for flushing of all the tasks till the last dequeued task.
// if (!task?.stop && task?.pending != null) pending = positionOf(this.#pending, task);
// call the callback and return true when not queued or pending
let position = (queued ?? 0) + pending;
callback?.(position);
Expand Down

0 comments on commit 25b5e72

Please sign in to comment.