diff --git a/lib/async/for-each.js b/lib/async/for-each.js
index 1ac9b2f..c89aa9b 100644
--- a/lib/async/for-each.js
+++ b/lib/async/for-each.js
@@ -5,24 +5,26 @@ module.exports = asyncForEach;
 /**
  * Simultaneously processes all items in the given array.
  *
+ * @param {DirectoryReader} ctx - The DirectoryReader context
+ * @param {object} dir - The current queue item
  * @param {array} array - The array to iterate over
  * @param {function} iterator - The function to call for each item in the array
  * @param {function} done - The function to call when all iterators have completed
  */
-function asyncForEach (array, iterator, done) {
+function asyncForEach (ctx, dir, array, iterator, done) {
   if (array.length === 0) {
     // NOTE: Normally a bad idea to mix sync and async, but it's safe here because
     // of the way that this method is currently used by DirectoryReader.
-    done();
+    done.call(ctx);
     return;
   }
 
   // Simultaneously process all items in the array.
   let pending = array.length;
   array.forEach(item => {
-    iterator(item, () => {
+    iterator.call(ctx, dir, item, () => {
       if (--pending === 0) {
-        done();
+        done.call(ctx);
       }
     });
   });
diff --git a/lib/directory-reader.js b/lib/directory-reader.js
index 37b19d5..75015af 100644
--- a/lib/directory-reader.js
+++ b/lib/directory-reader.js
@@ -78,9 +78,11 @@ class DirectoryReader {
       try {
         // Process each item in the directory (simultaneously, if async)
         facade.forEach(
+          this,
+          dir,
           items,
-          this.processItem.bind(this, dir),
-          this.finishedReadingDirectory.bind(this, dir)
+          this.processItem,
+          this.finishedReadingDirectory
         );
       }
       catch (err2) {
diff --git a/lib/sync/for-each.js b/lib/sync/for-each.js
index c5ec088..c9cf8cf 100644
--- a/lib/sync/for-each.js
+++ b/lib/sync/for-each.js
@@ -5,18 +5,20 @@ module.exports = syncForEach;
 /**
  * A facade that allows {@link Array.forEach} to be called as though it were asynchronous.
  *
+ * @param {DirectoryReader} ctx - The DirectoryReader context
+ * @param {object} dir - The current queue item
  * @param {array} array - The array to iterate over
  * @param {function} iterator - The function to call for each item in the array
  * @param {function} done - The function to call when all iterators have completed
  */
-function syncForEach (array, iterator, done) {
+function syncForEach (ctx, dir, array, iterator, done) {
   array.forEach(item => {
-    iterator(item, () => {
+    iterator.call(ctx, dir, item, () => {
       // Note: No error-handling here because this is currently only ever called
       // by DirectoryReader, which never passes an `error` parameter to the callback.
       // Instead, DirectoryReader emits an "error" event if an error occurs.
     });
   });
 
-  done();
+  done.call(ctx);
 }
diff --git a/package-lock.json b/package-lock.json
index df3a4d2..62f3ee1 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -1,6 +1,6 @@
 {
   "name": "readdir-enhanced",
-  "version": "2.1.0",
+  "version": "2.2.0",
   "lockfileVersion": 1,
   "requires": true,
   "dependencies": {
diff --git a/package.json b/package.json
index 576658a..0b683e1 100644
--- a/package.json
+++ b/package.json
@@ -55,4 +55,4 @@
   "engines": {
     "node": ">=4"
   }
-}
\ No newline at end of file
+}