diff --git a/lib/Open/directory.js b/lib/Open/directory.js
index ddbe097..37be634 100644
--- a/lib/Open/directory.js
+++ b/lib/Open/directory.js
@@ -93,7 +93,11 @@ module.exports = function centralDirectory(source, options) {
   return source.size()
     .then(function(size) {
       sourceSize = size;
-      source.stream(Math.max(0,size-tailSize)).pipe(endDir);
+
+      source.stream(Math.max(0,size-tailSize))
+        .on('error', function (error) { endDir.emit('error', error) })
+        .pipe(endDir);
+
       return endDir.pull(signature);
     })
     .then(function() {