summaryrefslogtreecommitdiff
path: root/ext/web/06_streams.js
diff options
context:
space:
mode:
authorBartek IwaƄczuk <biwanczuk@gmail.com>2022-04-21 02:22:55 +0200
committerGitHub <noreply@github.com>2022-04-21 02:22:55 +0200
commit03019e778189b38938f1238f22652162de5a7434 (patch)
treecf16b44be07c1c488ffe4f31fe77eab7f6bd8c95 /ext/web/06_streams.js
parentaaaa877d91c5f8b88722fd1ec725791b0eb4efe0 (diff)
Revert various PRs related to "ext/http" (#14339)
* Revert "feat(ext/http): stream auto resp body compression (#14325)" * Revert "core: introduce `resource.read_return` (#14331)" * Revert "perf(http): optimize `ReadableStream`s backed by a resource (#14284)"
Diffstat (limited to 'ext/web/06_streams.js')
-rw-r--r--ext/web/06_streams.js42
1 files changed, 0 insertions, 42 deletions
diff --git a/ext/web/06_streams.js b/ext/web/06_streams.js
index 492694563..6daea0898 100644
--- a/ext/web/06_streams.js
+++ b/ext/web/06_streams.js
@@ -8,7 +8,6 @@
"use strict";
((window) => {
- const core = window.Deno.core;
const webidl = window.__bootstrap.webidl;
const { add, remove, signalAbort, newSignal, AbortSignalPrototype } =
window.__bootstrap.abortSignal;
@@ -641,41 +640,6 @@
return stream[_disturbed];
}
- const DEFAULT_CHUNK_SIZE = 64 * 1024; // 64 KiB
-
- function readableStreamForRid(rid) {
- const stream = new ReadableStream({
- type: "bytes",
- async pull(controller) {
- const v = controller.byobRequest.view;
- try {
- const bytesRead = await core.read(rid, v);
- if (bytesRead === 0) {
- core.tryClose(rid);
- controller.close();
- controller.byobRequest.respond(0);
- } else {
- controller.byobRequest.respond(bytesRead);
- }
- } catch (e) {
- controller.error(e);
- core.tryClose(rid);
- }
- },
- cancel() {
- core.tryClose(rid);
- },
- autoAllocateChunkSize: DEFAULT_CHUNK_SIZE,
- });
-
- stream[_maybeRid] = rid;
- return stream;
- }
-
- function getReadableStreamRid(stream) {
- return stream[_maybeRid];
- }
-
/**
* @param {unknown} value
* @returns {value is WritableStream}
@@ -4324,7 +4288,6 @@
WeakMapPrototypeSet(countSizeFunctionWeakMap, globalObject, size);
}
- const _maybeRid = Symbol("[[maybeRid]]");
/** @template R */
class ReadableStream {
/** @type {ReadableStreamDefaultController | ReadableByteStreamController} */
@@ -4339,8 +4302,6 @@
[_state];
/** @type {any} */
[_storedError];
- /** @type {number | null} */
- [_maybeRid] = null;
/**
* @param {UnderlyingSource<R>=} underlyingSource
@@ -5879,9 +5840,6 @@
errorReadableStream,
createProxy,
writableStreamClose,
- readableStreamClose,
- readableStreamForRid,
- getReadableStreamRid,
Deferred,
// Exposed in global runtime scope
ByteLengthQueuingStrategy,