Improve process handling during pause and resume operations

Author: richorama

index.min.js

@@ -117,8 +117,10 @@ function process() {
 
   const item = queue.pop()
 
-  // Skip if request already in flight
+  // Skip if request already in flight - but keep this worker running
   if (callRecords[item.domain]) {
+    // Put item back in queue and try another
+    queue.unshift(item)
     return setTimeout(process, CONFIG.RETRY_DELAY_MS)
   }
 
@@ -407,6 +409,13 @@ export const pause = () => {
  */
 export const resume = () => {
   state.isPaused = false
+  
+  // Clear any stale call records from before pause
+  // This ensures workers don't skip requests thinking they're already in flight
+  Object.keys(callRecords).forEach(domain => {
+    delete callRecords[domain]
+  })
+  
   pauseCallbacks.forEach(callback => {
     try {
       callback(false)
@@ -415,7 +424,7 @@ export const resume = () => {
     }
   })
 
-  // Restart workers
+  // Restart full set of workers to ensure proper concurrency
   for (let i = 0; i < CONFIG.CONCURRENCY; i++) {
     setTimeout(process, i * 10)
   }
@@ -441,7 +450,7 @@ export const onPauseChange = (callback) => {
   return () => {
     const index = pauseCallbacks.indexOf(callback)
     if (index > -1) {
-      pauseCallbacks.splice(index, 1)
+      pauseCallbacks.splice(index, 1 * 100)
     }
   }
 }