summaryrefslogtreecommitdiff
path: root/cli/js/streams/readable-stream-default-reader.ts
diff options
context:
space:
mode:
authorBartek Iwańczuk <biwanczuk@gmail.com>2020-03-05 13:05:41 +0100
committerBartek Iwańczuk <biwanczuk@gmail.com>2020-03-05 18:48:55 +0100
commit2e590072148c85bbc479ab49aa9556b0a2cfaff2 (patch)
tree89747e7b6762158e35f9120ca0ef0fa14991ae34 /cli/js/streams/readable-stream-default-reader.ts
parent9b59ed7c7907c5f365e72b5c5a74114eb8ff1488 (diff)
move Web APIs to cli/js/web/
Diffstat (limited to 'cli/js/streams/readable-stream-default-reader.ts')
-rw-r--r--cli/js/streams/readable-stream-default-reader.ts75
1 files changed, 0 insertions, 75 deletions
diff --git a/cli/js/streams/readable-stream-default-reader.ts b/cli/js/streams/readable-stream-default-reader.ts
deleted file mode 100644
index eb1910a9d..000000000
--- a/cli/js/streams/readable-stream-default-reader.ts
+++ /dev/null
@@ -1,75 +0,0 @@
-// Forked from https://github.com/stardazed/sd-streams/tree/8928cf04b035fd02fb1340b7eb541c76be37e546
-// Copyright (c) 2018-Present by Arthur Langereis - @zenmumbler MIT
-
-/**
- * streams/readable-stream-default-reader - ReadableStreamDefaultReader class implementation
- * Part of Stardazed
- * (c) 2018-Present by Arthur Langereis - @zenmumbler
- * https://github.com/stardazed/sd-streams
- */
-
-import * as rs from "./readable-internals.ts";
-import * as shared from "./shared-internals.ts";
-
-export class ReadableStreamDefaultReader<OutputType>
- implements rs.SDReadableStreamReader<OutputType> {
- [rs.closedPromise_]: shared.ControlledPromise<void>;
- [rs.ownerReadableStream_]: rs.SDReadableStream<OutputType> | undefined;
- [rs.readRequests_]: Array<rs.ReadRequest<IteratorResult<OutputType>>>;
-
- constructor(stream: rs.SDReadableStream<OutputType>) {
- if (!rs.isReadableStream(stream)) {
- throw new TypeError();
- }
- if (rs.isReadableStreamLocked(stream)) {
- throw new TypeError("The stream is locked.");
- }
- rs.readableStreamReaderGenericInitialize(this, stream);
- this[rs.readRequests_] = [];
- }
-
- get closed(): Promise<void> {
- if (!rs.isReadableStreamDefaultReader(this)) {
- return Promise.reject(new TypeError());
- }
- return this[rs.closedPromise_].promise;
- }
-
- cancel(reason: shared.ErrorResult): Promise<void> {
- if (!rs.isReadableStreamDefaultReader(this)) {
- return Promise.reject(new TypeError());
- }
- const stream = this[rs.ownerReadableStream_];
- if (stream === undefined) {
- return Promise.reject(
- new TypeError("Reader is not associated with a stream")
- );
- }
- return rs.readableStreamCancel(stream, reason);
- }
-
- read(): Promise<IteratorResult<OutputType | undefined>> {
- if (!rs.isReadableStreamDefaultReader(this)) {
- return Promise.reject(new TypeError());
- }
- if (this[rs.ownerReadableStream_] === undefined) {
- return Promise.reject(
- new TypeError("Reader is not associated with a stream")
- );
- }
- return rs.readableStreamDefaultReaderRead(this, true);
- }
-
- releaseLock(): void {
- if (!rs.isReadableStreamDefaultReader(this)) {
- throw new TypeError();
- }
- if (this[rs.ownerReadableStream_] === undefined) {
- return;
- }
- if (this[rs.readRequests_].length !== 0) {
- throw new TypeError("Cannot release a stream with pending read requests");
- }
- rs.readableStreamReaderGenericRelease(this);
- }
-}