summaryrefslogtreecommitdiff
path: root/cli/js/web/streams/readable_stream_async_iterator.ts
diff options
context:
space:
mode:
authorDavid Sherret <dsherret@users.noreply.github.com>2020-07-14 15:24:17 -0400
committerGitHub <noreply@github.com>2020-07-14 15:24:17 -0400
commitcde4dbb35132848ffece59ef9cfaccff32347124 (patch)
treecc7830968c6decde704c8cfb83c9185193dc698f /cli/js/web/streams/readable_stream_async_iterator.ts
parent9eca71caa1674c31f9cc5d4e86c03f10b59e0a00 (diff)
Use dprint for internal formatting (#6682)
Diffstat (limited to 'cli/js/web/streams/readable_stream_async_iterator.ts')
-rw-r--r--cli/js/web/streams/readable_stream_async_iterator.ts31
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);