diff options
author | Bartek Iwańczuk <biwanczuk@gmail.com> | 2020-03-05 13:05:41 +0100 |
---|---|---|
committer | Bartek Iwańczuk <biwanczuk@gmail.com> | 2020-03-05 18:48:55 +0100 |
commit | 2e590072148c85bbc479ab49aa9556b0a2cfaff2 (patch) | |
tree | 89747e7b6762158e35f9120ca0ef0fa14991ae34 /cli/js/streams/readable-stream-default-reader.ts | |
parent | 9b59ed7c7907c5f365e72b5c5a74114eb8ff1488 (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.ts | 75 |
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); - } -} |