atomic-queue - npm Package Compare versions

Comparing version 5.0.2 to 5.0.3

index.js

@@ -25,3 +25,3 @@ var events = require('events')
   this.opts = opts
-  
+
   this.pool = createPool(worker, opts)
@@ -40,2 +40,6 @@ this.changes = createChangeDB({
   this.stream._queue = this
+  //
+  // Make the reference to the pool available so we can access it via the stream
+  //
+  this.stream.pool = this.pool
 
@@ -103,3 +107,3 @@ this.pool.on('start', function start (data, worker, change) {
       finish(self.inflight)
-      
+
       function finish (inflight) {
@@ -197,3 +201,3 @@ debug('finish?', [self.pending, self.latestChange, inflight.since])
   }
-  
+
   if (typeof startIndex === 'undefined') return {since: lastChange, jobs: {}} // all workers are done
@@ -200,0 +204,0 @@ else inflight = inflight.slice(startIndex)

package.json

 {
   "name": "atomic-queue",
-  "version": "5.0.2",
+  "version": "5.0.3",
   "description": "a crash friendly queue that persists queue state and can restart. uses a worker pool and has configurable concurrency",
@@ -5,0 +5,0 @@ "main": "index.js",

test.js

@@ -12,3 +12,3 @@ var test = require('tape')
   })
-  
+
   queue.write('a')
@@ -15,0 +15,0 @@ queue.write('b')

No alert changes

Improved metrics

Total package byte prevSize

12910

3.67%

Number of package files

9

12.5%

Lines of code

304

1.33%

No dependency changes