From fa61956f03491101b6ef64423ea2f1f73af26a73 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Bartek=20Iwa=C5=84czuk?= <biwanczuk@gmail.com>
Date: Sun, 19 Jul 2020 19:49:44 +0200
Subject: Port internal TS code to JS (#6793)

Co-authored-by: Ryan Dahl <ry@tinyclouds.org>
---
 .../web/streams/readable_stream_async_iterator.ts  | 80 ----------------------
 1 file changed, 80 deletions(-)
 delete mode 100644 cli/js/web/streams/readable_stream_async_iterator.ts

(limited to 'cli/js/web/streams/readable_stream_async_iterator.ts')

diff --git a/cli/js/web/streams/readable_stream_async_iterator.ts b/cli/js/web/streams/readable_stream_async_iterator.ts
deleted file mode 100644
index c6b9759a5..000000000
--- a/cli/js/web/streams/readable_stream_async_iterator.ts
+++ /dev/null
@@ -1,80 +0,0 @@
-// Copyright 2018-2020 the Deno authors. All rights reserved. MIT license.
-
-import * as sym from "./symbols.ts";
-import {
-  isReadableStreamAsyncIterator,
-  ReadableStreamAsyncIterator,
-  readableStreamCreateReadResult,
-  readableStreamReaderGenericCancel,
-  readableStreamReaderGenericRelease,
-  readableStreamDefaultReaderRead,
-} from "./internals.ts";
-import { assert } from "../../util.ts";
-
-// eslint-disable-next-line @typescript-eslint/no-explicit-any
-const AsyncIteratorPrototype: AsyncIterableIterator<any> = Object
-  .getPrototypeOf(Object.getPrototypeOf(async function* () {}).prototype);
-
-export const ReadableStreamAsyncIteratorPrototype: ReadableStreamAsyncIterator =
-  Object.setPrototypeOf({
-    next(
-      this: ReadableStreamAsyncIterator,
-      // eslint-disable-next-line @typescript-eslint/no-explicit-any
-    ): Promise<ReadableStreamReadResult<any>> {
-      if (!isReadableStreamAsyncIterator(this)) {
-        return Promise.reject(
-          new TypeError("invalid ReadableStreamAsyncIterator."),
-        );
-      }
-      const reader = this[sym.asyncIteratorReader];
-      if (!reader[sym.ownerReadableStream]) {
-        return Promise.reject(
-          new TypeError("reader owner ReadableStream is undefined."),
-        );
-      }
-      return readableStreamDefaultReaderRead(reader).then((result) => {
-        assert(typeof result === "object");
-        const { done } = result;
-        assert(typeof done === "boolean");
-        if (done) {
-          readableStreamReaderGenericRelease(reader);
-        }
-        const { value } = result;
-        return readableStreamCreateReadResult(value, done, true);
-      });
-    },
-    return(
-      this: ReadableStreamAsyncIterator,
-      // eslint-disable-next-line @typescript-eslint/no-explicit-any
-      value?: any | PromiseLike<any>,
-      // eslint-disable-next-line @typescript-eslint/no-explicit-any
-    ): Promise<ReadableStreamReadResult<any>> {
-      if (!isReadableStreamAsyncIterator(this)) {
-        return Promise.reject(
-          new TypeError("invalid ReadableStreamAsyncIterator."),
-        );
-      }
-      const reader = this[sym.asyncIteratorReader];
-      if (!reader[sym.ownerReadableStream]) {
-        return Promise.reject(
-          new TypeError("reader owner ReadableStream is undefined."),
-        );
-      }
-      if (reader[sym.readRequests].length) {
-        return Promise.reject(
-          new TypeError("reader has outstanding read requests."),
-        );
-      }
-      if (!this[sym.preventCancel]) {
-        const result = readableStreamReaderGenericCancel(reader, value);
-        readableStreamReaderGenericRelease(reader);
-        return result.then(() =>
-          readableStreamCreateReadResult(value, true, true)
-        );
-      }
-      readableStreamReaderGenericRelease(reader);
-      return Promise.resolve(
-        readableStreamCreateReadResult(value, true, true),
-      );
-    },
-  }, AsyncIteratorPrototype);
-- 
cgit v1.2.3