diff --git a/lib/caching.js b/lib/caching.js
index 6d9abd1..266b987 100644
--- a/lib/caching.js
+++ b/lib/caching.js
@@ -49,7 +49,7 @@ var caching = function (args) {
                     var work_args = Array.prototype.slice.call(arguments, 0);
                     if (work_args[0]) { // assume first arg is an error
                         self.queues[key].forEach(function (done) {
-                            done.apply(null, work_args);
+                            done.call(null, work_args[0]);
                         });
                         delete self.queues[key];
                         return;
@@ -61,14 +61,11 @@ var caching = function (args) {
                                 done.call(null, err);
                             });
                         }
-                        else if (!err) {
+                        else {
                             self.queues[key].forEach(function (done) {
                                 done.apply(null, work_args);
                             });
                         }
-                        else {
-                          return;
-                        }
 
                         delete self.queues[key];
                     });