From 6abf126c2a7a451cded8c6b5e6ddf1b69c84055d Mon Sep 17 00:00:00 2001
From: Casper Beyer <caspervonb@pm.me>
Date: Tue, 2 Feb 2021 19:05:46 +0800
Subject: chore: remove std directory (#9361)

This removes the std folder from the tree.

Various parts of the tests are pretty tightly dependent
on std (47 direct imports and 75 indirect imports, not
counting the cli tests that use them as fixtures) so I've
added std as a submodule for now.
---
 std/node/_stream/from.ts | 102 -----------------------------------------------
 1 file changed, 102 deletions(-)
 delete mode 100644 std/node/_stream/from.ts

(limited to 'std/node/_stream/from.ts')

diff --git a/std/node/_stream/from.ts b/std/node/_stream/from.ts
deleted file mode 100644
index 652c17715..000000000
--- a/std/node/_stream/from.ts
+++ /dev/null
@@ -1,102 +0,0 @@
-// Copyright Node.js contributors. All rights reserved. MIT License.
-import { Buffer } from "../buffer.ts";
-import Readable from "./readable.ts";
-import type { ReadableOptions } from "./readable.ts";
-import { ERR_INVALID_ARG_TYPE, ERR_STREAM_NULL_VALUES } from "../_errors.ts";
-
-export default function from(
-  // deno-lint-ignore no-explicit-any
-  iterable: Iterable<any> | AsyncIterable<any>,
-  opts?: ReadableOptions,
-) {
-  let iterator:
-    // deno-lint-ignore no-explicit-any
-    | Iterator<any, any, undefined>
-    // deno-lint-ignore no-explicit-any
-    | AsyncIterator<any, any, undefined>;
-  if (typeof iterable === "string" || iterable instanceof Buffer) {
-    return new Readable({
-      objectMode: true,
-      ...opts,
-      read() {
-        this.push(iterable);
-        this.push(null);
-      },
-    });
-  }
-
-  if (Symbol.asyncIterator in iterable) {
-    // deno-lint-ignore no-explicit-any
-    iterator = (iterable as AsyncIterable<any>)[Symbol.asyncIterator]();
-  } else if (Symbol.iterator in iterable) {
-    // deno-lint-ignore no-explicit-any
-    iterator = (iterable as Iterable<any>)[Symbol.iterator]();
-  } else {
-    throw new ERR_INVALID_ARG_TYPE("iterable", ["Iterable"], iterable);
-  }
-
-  const readable = new Readable({
-    objectMode: true,
-    highWaterMark: 1,
-    ...opts,
-  });
-
-  // Reading boolean to protect against _read
-  // being called before last iteration completion.
-  let reading = false;
-
-  // needToClose boolean if iterator needs to be explicitly closed
-  let needToClose = false;
-
-  readable._read = function () {
-    if (!reading) {
-      reading = true;
-      next();
-    }
-  };
-
-  readable._destroy = function (error, cb) {
-    if (needToClose) {
-      needToClose = false;
-      close().then(
-        () => queueMicrotask(() => cb(error)),
-        (e) => queueMicrotask(() => cb(error || e)),
-      );
-    } else {
-      cb(error);
-    }
-  };
-
-  async function close() {
-    if (typeof iterator.return === "function") {
-      const { value } = await iterator.return();
-      await value;
-    }
-  }
-
-  async function next() {
-    try {
-      needToClose = false;
-      const { value, done } = await iterator.next();
-      needToClose = !done;
-      if (done) {
-        readable.push(null);
-      } else if (readable.destroyed) {
-        await close();
-      } else {
-        const res = await value;
-        if (res === null) {
-          reading = false;
-          throw new ERR_STREAM_NULL_VALUES();
-        } else if (readable.push(res)) {
-          next();
-        } else {
-          reading = false;
-        }
-      }
-    } catch (err) {
-      readable.destroy(err);
-    }
-  }
-  return readable;
-}
-- 
cgit v1.2.3