refactor: deduplicate PriorityQueue scheduling to reduce bundle size

Extract shared scheduling logic into private scheduleItem() method,
reused by both pushWithBackoff and pushWithDelay. Brings browser bundle
back under the 29.7 kB size limit.

Author: MichaelGHSeg

packages/core/src/priority-queue/index.ts

@@ -52,30 +52,19 @@ export class PriorityQueue<Item extends QueueItem = QueueItem> extends Emitter {
       return this.push(item)[0]
     }
 
-    const attempt = this.updateAttempts(item)
-
-    if (attempt > this.maxAttempts || this.includes(item)) {
-      return false
-    }
-
-    let timeout = backoff({ attempt: attempt - 1 })
+    let timeout = backoff({ attempt: this.getAttempts(item) })
     if (minTimeout > 0 && timeout < minTimeout) {
       timeout = minTimeout
     }
 
-    setTimeout(() => {
-      this.queue.push(item)
-      // remove from future list
-      this.future = this.future.filter((f) => f.id !== item.id)
-      // Lets listeners know that a 'future' message is now available in the queue
-      this.emit(ON_REMOVE_FROM_FUTURE)
-    }, timeout)
-
-    this.future.push(item)
-    return true
+    return this.scheduleItem(item, timeout)
   }
 
   pushWithDelay(item: Item, delay: number): boolean {
+    return this.scheduleItem(item, delay)
+  }
+
+  private scheduleItem(item: Item, timeout: number): boolean {
     const attempt = this.updateAttempts(item)
 
     if (attempt > this.maxAttempts || this.includes(item)) {
@@ -86,7 +75,7 @@ export class PriorityQueue<Item extends QueueItem = QueueItem> extends Emitter {
       this.queue.push(item)
       this.future = this.future.filter((f) => f.id !== item.id)
       this.emit(ON_REMOVE_FROM_FUTURE)
-    }, delay)
+    }, timeout)
 
     this.future.push(item)
     return true