nodejs
diff --git a/Collapse file
‎doc/api/stream.md‎
Copy file name to clipboardExpand all lines: doc/api/stream.md
+11-3Lines changed: 11 additions & 3 deletions
Display the source diff
Display the rich diff b/Collapse file
‎doc/api/stream.md‎
Copy file name to clipboardExpand all lines: doc/api/stream.md
+11-3Lines changed: 11 additions & 3 deletions
Display the source diff
Display the rich diff
@@ -2644,15 +2644,23 @@ const finished = util.promisify(stream.finished);
 
 const writable = fs.createWriteStream('./file');
 
-(async function() {
+async function pump(iterator, writable) {
   for await (const chunk of iterator) {
     // Handle backpressure on write().
-    if (!writable.write(chunk))
+    if (!writable.write(chunk)) {
+      if (writable.destroyed) return;
       await once(writable, 'drain');
+    }
   }
   writable.end();
+}
+
+(async function() {
   // Ensure completion without errors.
-  await finished(writable);
+  await Promise.all([
+    pump(iterator, writable),
+    finished(writable)
+  ]);
 })();
 ```