feat(std/node/stream): Add Duplex, Transform, Passthrough, pipeline, finished and promises (#7940)

1 files changed, 42 insertions, 0 deletions

diff --git a/std/node/_stream/promises.ts b/std/node/_stream/promises.ts
new file mode 100644
index 000000000..1adf4ea3f
--- /dev/null
+++ b/std/node/_stream/promises.ts
@@ -0,0 +1,42 @@
+// Copyright Node.js contributors. All rights reserved. MIT License.
+import pl from "./pipeline.ts";
+import type { PipelineArguments } from "./pipeline.ts";
+import eos from "./end_of_stream.ts";
+import type {
+  FinishedOptions,
+  StreamImplementations as FinishedStreams,
+} from "./end_of_stream.ts";
+
+export function pipeline(...streams: PipelineArguments) {
+  return new Promise((resolve, reject) => {
+    pl(
+      ...streams,
+      (err, value) => {
+        if (err) {
+          reject(err);
+        } else {
+          resolve(value);
+        }
+      },
+    );
+  });
+}
+
+export function finished(
+  stream: FinishedStreams,
+  opts?: FinishedOptions,
+) {
+  return new Promise<void>((resolve, reject) => {
+    eos(
+      stream,
+      opts || null,
+      (err) => {
+        if (err) {
+          reject(err);
+        } else {
+          resolve();
+        }
+      },
+    );
+  });
+}