diff options
author | Bartek IwaĆczuk <biwanczuk@gmail.com> | 2020-07-19 19:49:44 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-07-19 19:49:44 +0200 |
commit | fa61956f03491101b6ef64423ea2f1f73af26a73 (patch) | |
tree | c3800702071ca78aa4dd71bdd0a59a9bbe460bdd /cli/js/web/streams/readable_stream_async_iterator.ts | |
parent | 53adde866dd399aa2509d14508642fce37afb8f5 (diff) |
Port internal TS code to JS (#6793)
Co-authored-by: Ryan Dahl <ry@tinyclouds.org>
Diffstat (limited to 'cli/js/web/streams/readable_stream_async_iterator.ts')
-rw-r--r-- | cli/js/web/streams/readable_stream_async_iterator.ts | 80 |
1 files changed, 0 insertions, 80 deletions
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); |