fix finish event on createWriteStream.

genie-js · Aug 20, 2017 · 370a015 · 370a015
1 parent 936b13f
commit 370a015
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 8 deletions.
diff --git a/package.json b/package.json
@@ -17,7 +17,7 @@
   "dependencies": {
     "awestruct": "^0.12.1",
     "blob-to-buffer": "^1.2.6",
-    "from2-blob": "^1.0.0",
+    "from2-blob": "^1.0.1",
     "from2-buffer": "^1.0.0",
     "is-buffer": "^1.1.5",
     "multistream": "^2.1.0",

diff --git a/src/DRS.js b/src/DRS.js
@@ -385,19 +385,21 @@ DRS.prototype.createWriteStream = function (type, id) {
   var table = getTable(this, type)
 
   var data = []
-  var cb = createFileBufferCallback(file, table, onfinish)
   var stream = to(function (chunk, enc, next) {
     data.push(chunk)
     next()
   }, function (next) {
+    var cb = createFileBufferCallback(file, table, onfinish)
     cb(null, Buffer.concat(data))
-    next()
-  })
 
-  function onfinish (err, file) {
-    if (err) stream.emit('error', err)
-    else stream.emit('meta', file)
-  }
+    function onfinish (err, file) {
+      if (!err) {
+        stream.emit('meta', file)
+      }
+
+      next(err)
+    }
+  })
 
   return stream
 }