diff --git a/lib/internal/streams/duplexify.js b/lib/internal/streams/duplexify.js
index 033884a5a7e5c9..12073bc9466c45 100644
--- a/lib/internal/streams/duplexify.js
+++ b/lib/internal/streams/duplexify.js
@@ -248,7 +248,7 @@ function fromAsyncGen(fn, destructor) {
         const { cb } = await _promise;
         process.nextTick(cb);
 
-        destructor();
+        process.nextTick(destructor);
       }
     }
   };