diff --git a/lib/utils.js b/lib/utils.js
index 42f9ac5..03c9fe9 100644
--- a/lib/utils.js
+++ b/lib/utils.js
@@ -1,7 +1,8 @@
 import { once } from "events";
-import { ReadStream, createReadStream, createWriteStream } from "fs";
+import { createReadStream, createWriteStream } from "fs";
 import { basename } from "path";
 import { createInterface } from "readline";
+import { pipeline } from "stream/promises";
 
 if (!globalThis.fetch) {
   globalThis.fetch = (await import("node-fetch")).default;
@@ -56,11 +57,8 @@ export const downloadFiles = async (filePath, urls) => {
   for (const response of responses) {
     const writeStream = createWriteStream(filePath, { flags: "a" });
 
-    ReadStream.from(response.body)
-      .on("end", () => {
-        writeStream.write("\n");
-      })
-      .pipe(writeStream);
+    await pipeline(response.body, writeStream, { end: false });
+    writeStream.end("\n");
   }
 };