diff options
Diffstat (limited to 'cli/js/web/streams/readable_stream_async_iterator.ts')
-rw-r--r-- | cli/js/web/streams/readable_stream_async_iterator.ts | 31 |
1 files changed, 15 insertions, 16 deletions
diff --git a/cli/js/web/streams/readable_stream_async_iterator.ts b/cli/js/web/streams/readable_stream_async_iterator.ts index cd656e73d..c6b9759a5 100644 --- a/cli/js/web/streams/readable_stream_async_iterator.ts +++ b/cli/js/web/streams/readable_stream_async_iterator.ts @@ -12,25 +12,24 @@ import { 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 -); +const AsyncIteratorPrototype: AsyncIterableIterator<any> = Object + .getPrototypeOf(Object.getPrototypeOf(async function* () {}).prototype); -export const ReadableStreamAsyncIteratorPrototype: ReadableStreamAsyncIterator = Object.setPrototypeOf( - { +export const ReadableStreamAsyncIteratorPrototype: ReadableStreamAsyncIterator = + Object.setPrototypeOf({ next( - this: ReadableStreamAsyncIterator + this: ReadableStreamAsyncIterator, // eslint-disable-next-line @typescript-eslint/no-explicit-any ): Promise<ReadableStreamReadResult<any>> { if (!isReadableStreamAsyncIterator(this)) { return Promise.reject( - new TypeError("invalid ReadableStreamAsyncIterator.") + new TypeError("invalid ReadableStreamAsyncIterator."), ); } const reader = this[sym.asyncIteratorReader]; if (!reader[sym.ownerReadableStream]) { return Promise.reject( - new TypeError("reader owner ReadableStream is undefined.") + new TypeError("reader owner ReadableStream is undefined."), ); } return readableStreamDefaultReaderRead(reader).then((result) => { @@ -47,23 +46,23 @@ export const ReadableStreamAsyncIteratorPrototype: ReadableStreamAsyncIterator = return( this: ReadableStreamAsyncIterator, // eslint-disable-next-line @typescript-eslint/no-explicit-any - value?: any | PromiseLike<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.") + new TypeError("invalid ReadableStreamAsyncIterator."), ); } const reader = this[sym.asyncIteratorReader]; if (!reader[sym.ownerReadableStream]) { return Promise.reject( - new TypeError("reader owner ReadableStream is undefined.") + new TypeError("reader owner ReadableStream is undefined."), ); } if (reader[sym.readRequests].length) { return Promise.reject( - new TypeError("reader has outstanding read requests.") + new TypeError("reader has outstanding read requests."), ); } if (!this[sym.preventCancel]) { @@ -74,8 +73,8 @@ export const ReadableStreamAsyncIteratorPrototype: ReadableStreamAsyncIterator = ); } readableStreamReaderGenericRelease(reader); - return Promise.resolve(readableStreamCreateReadResult(value, true, true)); + return Promise.resolve( + readableStreamCreateReadResult(value, true, true), + ); }, - }, - AsyncIteratorPrototype -); + }, AsyncIteratorPrototype); |