1 files changed, 0 insertions, 81 deletions
diff --git a/std/node/_stream/stream.ts b/std/node/_stream/stream.ts
deleted file mode 100644
index 4daafc77b..000000000
--- a/std/node/_stream/stream.ts
+++ /dev/null
@@ -1,81 +0,0 @@
-// Copyright Node.js contributors. All rights reserved. MIT License.
-import { Buffer } from "../buffer.ts";
-import EventEmitter from "../events.ts";
-import type Readable from "./readable.ts";
-import type Writable from "./writable.ts";
-import { types } from "../util.ts";
-
-class Stream extends EventEmitter {
-  constructor() {
-    super();
-  }
-
-  static _isUint8Array = types.isUint8Array;
-  static _uint8ArrayToBuffer = (chunk: Uint8Array) => Buffer.from(chunk);
-
-  pipe(dest: Readable | Writable, options?: { end?: boolean }) {
-    // deno-lint-ignore no-this-alias
-    const source = this;
-
-    //TODO(Soremwar)
-    //isStdio exist on stdin || stdout only, which extend from Duplex
-    //if (!dest._isStdio && (options?.end ?? true)) {
-    //Find an alternative to be able to pipe streams to stdin & stdout
-    //Port them as well?
-    if (options?.end ?? true) {
-      source.on("end", onend);
-      source.on("close", onclose);
-    }
-
-    let didOnEnd = false;
-    function onend() {
-      if (didOnEnd) return;
-      didOnEnd = true;
-
-      // 'end' is only called on Writable streams
-      (dest as Writable).end();
-    }
-
-    function onclose() {
-      if (didOnEnd) return;
-      didOnEnd = true;
-
-      if (typeof dest.destroy === "function") dest.destroy();
-    }
-
-    // Don't leave dangling pipes when there are errors.
-    function onerror(this: Stream, er: Error) {
-      cleanup();
-      if (this.listenerCount("error") === 0) {
-        throw er; // Unhandled stream error in pipe.
-      }
-    }
-
-    source.on("error", onerror);
-    dest.on("error", onerror);
-
-    // Remove all the event listeners that were added.
-    function cleanup() {
-      source.removeListener("end", onend);
-      source.removeListener("close", onclose);
-
-      source.removeListener("error", onerror);
-      dest.removeListener("error", onerror);
-
-      source.removeListener("end", cleanup);
-      source.removeListener("close", cleanup);
-
-      dest.removeListener("close", cleanup);
-    }
-
-    source.on("end", cleanup);
-    source.on("close", cleanup);
-
-    dest.on("close", cleanup);
-    dest.emit("pipe", source);
-
-    return dest;
-  }
-}
-
-export default Stream;