level-trigger - npm Package Compare versions

Comparing version 1.2.2 to 1.3.0

index.js

@@ -63,3 +63,3 @@ var shasum = require('shasum')
       }
-      
+
       jobs.del(data.key, function (err) {
@@ -104,6 +104,11 @@ if(err) return retry.push(data)
   jobs.start = function () {
+    var hadData = false;
     input.createReadStream({valueEncoding: 'utf8'})
       .on('data', function (data) {
+        hadData = true
         doHook(data, doJob)
       })
+      .on('end', function () {
+        if (! hadData && ! working) jobs.emit('complete')
+      })
     return jobs
@@ -110,0 +115,0 @@ }

package.json

 {
   "name": "level-trigger",
-  "version": "1.2.2",
+  "version": "1.3.0",
   "homepage": "https://github.com/dominictarr/level-trigger",
@@ -5,0 +5,0 @@ "repository": {

No alert changes

Improved metrics

Total package byte prevSize

10076

increased by1.41%

Lines of code

245

increased by2.08%

No dependency changes