diff --git a/lib/internal/streams/async_iterator.js b/lib/internal/streams/async_iterator.js
index 90960f5a3842e3..7eaef69508690d 100644
--- a/lib/internal/streams/async_iterator.js
+++ b/lib/internal/streams/async_iterator.js
@@ -37,8 +37,8 @@ function onReadable(iter) {
 }
 
 function wrapForNext(lastPromise, iter) {
-  return function(resolve, reject) {
-    lastPromise.then(function() {
+  return (resolve, reject) => {
+    lastPromise.then(() => {
       iter[kHandlePromise](resolve, reject);
     }, reject);
   };