summaryrefslogtreecommitdiff
path: root/cli/js/web/streams/writable-stream.ts
diff options
context:
space:
mode:
Diffstat (limited to 'cli/js/web/streams/writable-stream.ts')
-rw-r--r--cli/js/web/streams/writable-stream.ts118
1 files changed, 0 insertions, 118 deletions
diff --git a/cli/js/web/streams/writable-stream.ts b/cli/js/web/streams/writable-stream.ts
deleted file mode 100644
index f231d78dc..000000000
--- a/cli/js/web/streams/writable-stream.ts
+++ /dev/null
@@ -1,118 +0,0 @@
-// TODO reenable this code when we enable writableStreams and transport types
-// // Forked from https://github.com/stardazed/sd-streams/tree/8928cf04b035fd02fb1340b7eb541c76be37e546
-// // Copyright (c) 2018-Present by Arthur Langereis - @zenmumbler MIT
-
-// /**
-// * streams/writable-stream - WritableStream class implementation
-// * Part of Stardazed
-// * (c) 2018-Present by Arthur Langereis - @zenmumbler
-// * https://github.com/stardazed/sd-streams
-// */
-
-// import * as ws from "./writable-internals.ts";
-// import * as shared from "./shared-internals.ts";
-// import {
-// WritableStreamDefaultController,
-// setUpWritableStreamDefaultControllerFromUnderlyingSink
-// } from "./writable-stream-default-controller.ts";
-// import { WritableStreamDefaultWriter } from "./writable-stream-default-writer.ts";
-// import { QueuingStrategy, QueuingStrategySizeCallback } from "../dom_types.d.ts";
-
-// export class WritableStream<InputType> {
-// [shared.state_]: ws.WritableStreamState;
-// [shared.storedError_]: shared.ErrorResult;
-// [ws.backpressure_]: boolean;
-// [ws.closeRequest_]: shared.ControlledPromise<void> | undefined;
-// [ws.inFlightWriteRequest_]: shared.ControlledPromise<void> | undefined;
-// [ws.inFlightCloseRequest_]: shared.ControlledPromise<void> | undefined;
-// [ws.pendingAbortRequest_]: ws.AbortRequest | undefined;
-// [ws.writableStreamController_]:
-// | ws.WritableStreamDefaultController<InputType>
-// | undefined;
-// [ws.writer_]: ws.WritableStreamDefaultWriter<InputType> | undefined;
-// [ws.writeRequests_]: Array<shared.ControlledPromise<void>>;
-
-// constructor(
-// sink: ws.WritableStreamSink<InputType> = {},
-// strategy: QueuingStrategy<InputType> = {}
-// ) {
-// ws.initializeWritableStream(this);
-// const sizeFunc = strategy.size;
-// const stratHWM = strategy.highWaterMark;
-// if (sink.type !== undefined) {
-// throw new RangeError("The type of an underlying sink must be undefined");
-// }
-
-// const sizeAlgorithm = shared.makeSizeAlgorithmFromSizeFunction(sizeFunc);
-// const highWaterMark = shared.validateAndNormalizeHighWaterMark(
-// stratHWM === undefined ? 1 : stratHWM
-// );
-
-// setUpWritableStreamDefaultControllerFromUnderlyingSink(
-// this,
-// sink,
-// highWaterMark,
-// sizeAlgorithm
-// );
-// }
-
-// get locked(): boolean {
-// if (!ws.isWritableStream(this)) {
-// throw new TypeError();
-// }
-// return ws.isWritableStreamLocked(this);
-// }
-
-// abort(reason?: shared.ErrorResult): Promise<void> {
-// if (!ws.isWritableStream(this)) {
-// return Promise.reject(new TypeError());
-// }
-// if (ws.isWritableStreamLocked(this)) {
-// return Promise.reject(new TypeError("Cannot abort a locked stream"));
-// }
-// return ws.writableStreamAbort(this, reason);
-// }
-
-// getWriter(): ws.WritableStreamWriter<InputType> {
-// if (!ws.isWritableStream(this)) {
-// throw new TypeError();
-// }
-// return new WritableStreamDefaultWriter(this);
-// }
-// }
-
-// export function createWritableStream<InputType>(
-// startAlgorithm: ws.StartAlgorithm,
-// writeAlgorithm: ws.WriteAlgorithm<InputType>,
-// closeAlgorithm: ws.CloseAlgorithm,
-// abortAlgorithm: ws.AbortAlgorithm,
-// highWaterMark?: number,
-// sizeAlgorithm?: QueuingStrategySizeCallback<InputType>
-// ): WritableStream<InputType> {
-// if (highWaterMark === undefined) {
-// highWaterMark = 1;
-// }
-// if (sizeAlgorithm === undefined) {
-// sizeAlgorithm = (): number => 1;
-// }
-// // Assert: ! IsNonNegativeNumber(highWaterMark) is true.
-
-// const stream = Object.create(WritableStream.prototype) as WritableStream<
-// InputType
-// >;
-// ws.initializeWritableStream(stream);
-// const controller = Object.create(
-// WritableStreamDefaultController.prototype
-// ) as WritableStreamDefaultController<InputType>;
-// ws.setUpWritableStreamDefaultController(
-// stream,
-// controller,
-// startAlgorithm,
-// writeAlgorithm,
-// closeAlgorithm,
-// abortAlgorithm,
-// highWaterMark,
-// sizeAlgorithm
-// );
-// return stream;
-// }