summaryrefslogtreecommitdiff
path: root/cli/js/web/streams/readable_stream_default_reader.ts
diff options
context:
space:
mode:
Diffstat (limited to 'cli/js/web/streams/readable_stream_default_reader.ts')
-rw-r--r--cli/js/web/streams/readable_stream_default_reader.ts92
1 files changed, 0 insertions, 92 deletions
diff --git a/cli/js/web/streams/readable_stream_default_reader.ts b/cli/js/web/streams/readable_stream_default_reader.ts
deleted file mode 100644
index 88260effb..000000000
--- a/cli/js/web/streams/readable_stream_default_reader.ts
+++ /dev/null
@@ -1,92 +0,0 @@
-// Copyright 2018-2020 the Deno authors. All rights reserved. MIT license.
-
-import {
- Deferred,
- isReadableStream,
- isReadableStreamDefaultReader,
- isReadableStreamLocked,
- readableStreamDefaultReaderRead,
- readableStreamReaderGenericCancel,
- readableStreamReaderGenericInitialize,
- readableStreamReaderGenericRelease,
-} from "./internals.ts";
-import type { ReadableStreamImpl } from "./readable_stream.ts";
-import * as sym from "./symbols.ts";
-import { customInspect } from "../console.ts";
-import { setFunctionName } from "../util.ts";
-
-// eslint-disable-next-line @typescript-eslint/no-explicit-any
-export class ReadableStreamDefaultReaderImpl<R = any>
- implements ReadableStreamDefaultReader<R> {
- [sym.closedPromise]: Deferred<void>;
- [sym.forAuthorCode]: boolean;
- [sym.ownerReadableStream]: ReadableStreamImpl<R>;
- [sym.readRequests]: Array<Deferred<ReadableStreamReadResult<R>>>;
-
- constructor(stream: ReadableStream<R>) {
- if (!isReadableStream(stream)) {
- throw new TypeError("stream is not a ReadableStream.");
- }
- if (isReadableStreamLocked(stream)) {
- throw new TypeError("stream is locked.");
- }
- readableStreamReaderGenericInitialize(this, stream);
- this[sym.readRequests] = [];
- }
-
- get closed(): Promise<void> {
- if (!isReadableStreamDefaultReader(this)) {
- return Promise.reject(
- new TypeError("Invalid ReadableStreamDefaultReader."),
- );
- }
- return (
- this[sym.closedPromise].promise ??
- Promise.reject(new TypeError("Invalid reader."))
- );
- }
-
- // eslint-disable-next-line @typescript-eslint/no-explicit-any
- cancel(reason?: any): Promise<void> {
- if (!isReadableStreamDefaultReader(this)) {
- return Promise.reject(
- new TypeError("Invalid ReadableStreamDefaultReader."),
- );
- }
- if (!this[sym.ownerReadableStream]) {
- return Promise.reject(new TypeError("Invalid reader."));
- }
- return readableStreamReaderGenericCancel(this, reason);
- }
-
- read(): Promise<ReadableStreamReadResult<R>> {
- if (!isReadableStreamDefaultReader(this)) {
- return Promise.reject(
- new TypeError("Invalid ReadableStreamDefaultReader."),
- );
- }
- if (!this[sym.ownerReadableStream]) {
- return Promise.reject(new TypeError("Invalid reader."));
- }
- return readableStreamDefaultReaderRead(this);
- }
-
- releaseLock(): void {
- if (!isReadableStreamDefaultReader(this)) {
- throw new TypeError("Invalid ReadableStreamDefaultReader.");
- }
- if (this[sym.ownerReadableStream] === undefined) {
- return;
- }
- if (this[sym.readRequests].length) {
- throw new TypeError("Cannot release lock with pending read requests.");
- }
- readableStreamReaderGenericRelease(this);
- }
-
- [customInspect](): string {
- return `${this.constructor.name} { closed: Promise }`;
- }
-}
-
-setFunctionName(ReadableStreamDefaultReaderImpl, "ReadableStreamDefaultReader");