Merge pull request #11 from ipfs/fix/error

fix(block-service): return errors for addBlock
ipfs · Apr 23, 2016 · 2cf6f1f · 2cf6f1f
2 parents d3e6baf + 0fea48d
commit 2cf6f1f
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/src/block-service.js b/src/block-service.js
@@ -10,8 +10,17 @@ const async = require('async')
 function BlockService (ipfsRepo, exchange) {
   this.addBlock = (block, callback) => {
     const ws = ipfsRepo.datastore.createWriteStream(block.key, block.extension)
+
+    let done = false
+
     ws.write(block.data)
-    ws.once('finish', callback)
+    ws.once('error', (err) => {
+      done = true
+      callback(err)
+    })
+    ws.once('finish', () => {
+      if (!done) callback()
+    })
     ws.end()
   }