fix(block-service): return errors for addBlock

ipfs · Apr 22, 2016 · 0fea48d · 0fea48d
1 parent d3e6baf
commit 0fea48d
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()
   }