diff options
| -rw-r--r-- | .eslintrc.js | 17 | ||||
| -rw-r--r-- | doc/api/globals.md | 187 | ||||
| -rw-r--r-- | doc/api/webstreams.md | 86 | ||||
| -rw-r--r-- | lib/.eslintrc.yaml | 34 | ||||
| -rw-r--r-- | lib/internal/blob.js | 1 | ||||
| -rw-r--r-- | lib/internal/bootstrap/browser.js | 54 | ||||
| -rw-r--r-- | test/common/index.js | 21 | ||||
| -rw-r--r-- | test/parallel/test-bootstrap-modules.js | 3 | ||||
| -rw-r--r-- | test/parallel/test-global-webstreams.js | 24 | ||||
| -rw-r--r-- | test/wpt/test-streams.js | 104 |
10 files changed, 410 insertions, 121 deletions
diff --git a/.eslintrc.js b/.eslintrc.js index d44e3f1414f..f6de7559cb4 100644 --- a/.eslintrc.js +++ b/.eslintrc.js @@ -317,11 +317,28 @@ module.exports = { 'node-core/no-duplicate-requires': 'error', }, globals: { + ByteLengthQueuingStrategy: 'readable', + CompressionStream: 'readable', + CountQueuingStrategy: 'readable', Crypto: 'readable', CryptoKey: 'readable', + DecompressionStream: 'readable', fetch: 'readable', FormData: 'readable', + ReadableStream: 'readable', + ReadableStreamDefaultReader: 'readable', + ReadableStreamBYOBReader: 'readable', + ReadableStreamBYOBRequest: 'readable', + ReadableByteStreamController: 'readable', + ReadableStreamDefaultController: 'readable', Response: 'readable', + TextDecoderStream: 'readable', + TextEncoderStream: 'readable', + TransformStream: 'readable', + TransformStreamDefaultController: 'readable', SubtleCrypto: 'readable', + WritableStream: 'readable', + WritableStreamDefaultWriter: 'readable', + WritableStreamDefaultController: 'readable', }, }; diff --git a/doc/api/globals.md b/doc/api/globals.md index 5d9e81d9afc..7274ff3d801 100644 --- a/doc/api/globals.md +++ b/doc/api/globals.md @@ -229,6 +229,16 @@ added: v0.1.103 Used to handle binary data. See the [buffer section][]. +## Class: `ByteLengthQueuingStrategy` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`ByteLengthQueuingStrategy`][]. + ## `__dirname` This variable may appear to be global but is not. See [`__dirname`][]. @@ -295,6 +305,16 @@ added: v0.0.1 [`clearTimeout`][] is described in the [timers][] section. +## Class: `CompressionStream` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`CompressionStream`][]. + ## `console` <!-- YAML @@ -307,6 +327,16 @@ added: v0.1.100 Used to print to stdout and stderr. See the [`console`][] section. +## Class: `CountQueuingStrategy` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`CountQueuingStrategy`][]. + ## `Crypto` <!-- YAML @@ -344,6 +374,16 @@ A browser-compatible implementation of {CryptoKey}. This global is available only if the Node.js binary was compiled with including support for the `crypto` module. +## Class: `DecompressionStream` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`DecompressionStream`][]. + ## `Event` <!-- YAML @@ -516,6 +556,66 @@ DataHandler.prototype.load = async function load(key) { }; ``` +## Class: `ReadableByteStreamController` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`ReadableByteStreamController`][]. + +## Class: `ReadableStream` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`ReadableStream`][]. + +## Class: `ReadableStreamBYOBReader` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`ReadableStreamBYOBReader`][]. + +## Class: `ReadableStreamBYOBRequest` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`ReadableStreamBYOBRequest`][]. + +## Class: `ReadableStreamDefaultController` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`ReadableStreamDefaultController`][]. + +## Class: `ReadableStreamDefaultReader` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`ReadableStreamDefaultReader`][]. + ## `require()` This variable may appear to be global but is not. See [`require()`][]. @@ -615,6 +715,16 @@ added: v11.0.0 The WHATWG `TextDecoder` class. See the [`TextDecoder`][] section. +## Class: `TextDecoderStream` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`TextDecoderStream`][]. + ## `TextEncoder` <!-- YAML @@ -625,6 +735,36 @@ added: v11.0.0 The WHATWG `TextEncoder` class. See the [`TextEncoder`][] section. +## Class: `TextEncoderStream` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`TextEncoderStream`][]. + +## Class: `TransformStream` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`TransformStream`][]. + +## Class: `TransformStreamDefaultController` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`TransformStreamDefaultController`][]. + ## `URL` <!-- YAML @@ -659,19 +799,66 @@ The object that acts as the namespace for all W3C [WebAssembly][webassembly-org] related functionality. See the [Mozilla Developer Network][webassembly-mdn] for usage and compatibility. +## Class: `WritableStream` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`WritableStream`][]. + +## Class: `WritableStreamDefaultController` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`WritableStreamDefaultController`][]. + +## Class: `WritableStreamDefaultWriter` + +<!-- YAML +added: REPLACEME +--> + +> Stability: 1 - Experimental. + +A browser-compatible implementation of [`WritableStreamDefaultWriter`][]. + [Web Crypto API]: webcrypto.md [`--experimental-global-webcrypto`]: cli.md#--experimental-global-webcrypto [`--no-experimental-fetch`]: cli.md#--no-experimental-fetch [`AbortController`]: https://developer.mozilla.org/en-US/docs/Web/API/AbortController +[`ByteLengthQueuingStrategy`]: webstreams.md#class-bytelengthqueuingstrategy +[`CompressionStream`]: webstreams.md#class-compressionstream +[`CountQueuingStrategy`]: webstreams.md#class-countqueuingstrategy [`DOMException`]: https://developer.mozilla.org/en-US/docs/Web/API/DOMException +[`DecompressionStream`]: webstreams.md#class-decompressionstream [`EventTarget` and `Event` API]: events.md#eventtarget-and-event-api [`MessageChannel`]: worker_threads.md#class-messagechannel [`MessageEvent`]: https://developer.mozilla.org/en-US/docs/Web/API/MessageEvent/MessageEvent [`MessagePort`]: worker_threads.md#class-messageport +[`ReadableByteStreamController`]: webstreams.md#class-readablebytestreamcontroller +[`ReadableStreamBYOBReader`]: webstreams.md#class-readablestreambyobreader +[`ReadableStreamBYOBRequest`]: webstreams.md#class-readablestreambyobrequest +[`ReadableStreamDefaultController`]: webstreams.md#class-readablestreamdefaultcontroller +[`ReadableStreamDefaultReader`]: webstreams.md#class-readablestreamdefaultreader +[`ReadableStream`]: webstreams.md#class-readablestream +[`TextDecoderStream`]: webstreams.md#class-textdecoderstream [`TextDecoder`]: util.md#class-utiltextdecoder +[`TextEncoderStream`]: webstreams.md#class-textencoderstream [`TextEncoder`]: util.md#class-utiltextencoder +[`TransformStreamDefaultController`]: webstreams.md#class-transformstreamdefaultcontroller +[`TransformStream`]: webstreams.md#class-transformstream [`URLSearchParams`]: url.md#class-urlsearchparams [`URL`]: url.md#class-url +[`WritableStreamDefaultController`]: webstreams.md#class-writablestreamdefaultcontroller +[`WritableStreamDefaultWriter`]: webstreams.md#class-writablestreamdefaultwriter +[`WritableStream`]: webstreams.md#class-writablestream [`__dirname`]: modules.md#__dirname [`__filename`]: modules.md#__filename [`buffer.atob()`]: buffer.md#bufferatobdata diff --git a/doc/api/webstreams.md b/doc/api/webstreams.md index cde2addc7d0..9f356360078 100644 --- a/doc/api/webstreams.md +++ b/doc/api/webstreams.md @@ -2,25 +2,17 @@ <!--introduced_in=v16.5.0--> -> Stability: 1 - Experimental - -An implementation of the [WHATWG Streams Standard][]. +<!-- YAML +added: v16.5.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: Use of this API no longer emit a runtime warning. +--> -```mjs -import { - ReadableStream, - WritableStream, - TransformStream, -} from 'node:stream/web'; -``` +> Stability: 1 - Experimental. -```cjs -const { - ReadableStream, - WritableStream, - TransformStream, -} = require('stream/web'); -``` +An implementation of the [WHATWG Streams Standard][]. ## Overview @@ -101,6 +93,10 @@ const stream = new ReadableStream({ <!-- YAML added: v16.5.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: This class is now exposed on the global object. --> #### `new ReadableStream([underlyingSource [, strategy]])` @@ -387,6 +383,10 @@ port2.postMessage(stream, [stream]); <!-- YAML added: v16.5.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: This class is now exposed on the global object. --> By default, calling `readableStream.getReader()` with no arguments @@ -454,6 +454,10 @@ Releases this reader's lock on the underlying {ReadableStream}. <!-- YAML added: v16.5.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: This class is now exposed on the global object. --> The `ReadableStreamBYOBReader` is an alternative consumer for @@ -701,6 +705,10 @@ Signals an error that causes the {ReadableStream} to error and close. <!-- YAML added: v16.5.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: This class is now exposed on the global object. --> When using `ReadableByteStreamController` in byte-oriented @@ -747,6 +755,10 @@ added: v16.5.0 <!-- YAML added: v16.5.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: This class is now exposed on the global object. --> The `WritableStream` is a destination to which stream data is sent. @@ -863,6 +875,10 @@ port2.postMessage(stream, [stream]); <!-- YAML added: v16.5.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: This class is now exposed on the global object. --> #### `new WritableStreamDefaultWriter(stream)` @@ -950,6 +966,10 @@ Appends a new chunk of data to the {WritableStream}'s queue. <!-- YAML added: v16.5.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: This class is now exposed on the global object. --> The `WritableStreamDefaultController` manage's the {WritableStream}'s @@ -980,6 +1000,10 @@ with currently pending writes canceled. <!-- YAML added: v16.5.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: This class is now exposed on the global object. --> A `TransformStream` consists of a {ReadableStream} and a {WritableStream} that @@ -1082,6 +1106,10 @@ port2.postMessage(stream, [stream]); <!-- YAML added: v16.5.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: This class is now exposed on the global object. --> The `TransformStreamDefaultController` manages the internal state @@ -1132,6 +1160,10 @@ to be abruptly closed with an error. <!-- YAML added: v16.5.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: This class is now exposed on the global object. --> #### `new ByteLengthQueuingStrategy(options)` @@ -1165,6 +1197,10 @@ added: v16.5.0 <!-- YAML added: v16.5.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: This class is now exposed on the global object. --> #### `new CountQueuingStrategy(options)` @@ -1198,6 +1234,10 @@ added: v16.5.0 <!-- YAML added: v16.6.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: This class is now exposed on the global object. --> #### `new TextEncoderStream()` @@ -1238,6 +1278,10 @@ added: v16.6.0 <!-- YAML added: v16.6.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: This class is now exposed on the global object. --> #### `new TextDecoderStream([encoding[, options]])` @@ -1309,6 +1353,10 @@ added: v16.6.0 <!-- YAML added: v17.0.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: This class is now exposed on the global object. --> #### `new CompressionStream(format)` @@ -1339,6 +1387,10 @@ added: v17.0.0 <!-- YAML added: v17.0.0 +changes: + - version: REPLACEME + pr-url: https://github.com/nodejs/node/pull/42225 + description: This class is now exposed on the global object. --> #### `new DecompressionStream(format)` diff --git a/lib/.eslintrc.yaml b/lib/.eslintrc.yaml index bb9edf87e1f..c1635e4cf08 100644 --- a/lib/.eslintrc.yaml +++ b/lib/.eslintrc.yaml @@ -43,6 +43,14 @@ rules: message: Use `const { BroadcastChannel } = require('internal/worker/io');` instead of the global. - name: Buffer message: Use `const { Buffer } = require('buffer');` instead of the global. + - name: ByteLengthQueuingStrategy + message: Use `const { ByteLengthQueuingStrategy } = require('internal/webstreams/queuingstrategies')` instead of the global. + - name: CompressionStream + message: Use `const { CompressionStream } = require('internal/webstreams/compression')` instead of the global. + - name: CountQueuingStrategy + message: Use `const { CountQueuingStrategy } = require('internal/webstreams/queuingstrategies')` instead of the global. + - name: DecompressionStream + message: Use `const { DecompressionStream } = require('internal/webstreams/compression')` instead of the global. - name: DOMException message: Use lazy function `const { lazyDOMException } = require('internal/util');` instead of the global. - name: Event @@ -63,6 +71,18 @@ rules: message: Use `const { MessageEvent } = require('internal/worker/io');` instead of the global. - name: MessagePort message: Use `const { MessagePort } = require('internal/worker/io');` instead of the global. + - name: ReadableStream + message: Use `const { ReadableStream } = require('internal/webstreams/readablestream')` instead of the global. + - name: ReadableStreamDefaultReader + message: Use `const { ReadableStreamDefaultReader } = require('internal/webstreams/readablestream')` instead of the global. + - name: ReadableStreamBYOBReader + message: Use `const { ReadableStreamBYOBReader } = require('internal/webstreams/readablestream')` instead of the global. + - name: ReadableStreamBYOBRequest + message: Use `const { ReadableStreamBYOBRequest } = require('internal/webstreams/readablestream')` instead of the global. + - name: ReadableByteStreamController + message: Use `const { ReadableByteStreamController } = require('internal/webstreams/readablestream')` instead of the global. + - name: ReadableStreamDefaultController + message: Use `const { ReadableStreamDefaultController } = require('internal/webstreams/readablestream')` instead of the global. - name: Request message: Use `const { Request } = require('internal/deps/undici/undici');` instead of the global. - name: Response @@ -73,8 +93,16 @@ rules: message: Use `const { SharedArrayBuffer } = globalThis;` instead of the global. - name: TextDecoder message: Use `const { TextDecoder } = require('internal/encoding');` instead of the global. + - name: TextDecoderStream + message: Use `const { TextDecoderStream } = require('internal/webstreams/encoding')` instead of the global. - name: TextEncoder message: Use `const { TextEncoder } = require('internal/encoding');` instead of the global. + - name: TextEncoderStream + message: Use `const { TextEncoderStream } = require('internal/webstreams/encoding')` instead of the global. + - name: TransformStream + message: Use `const { TransformStream } = require('internal/webstreams/transformstream')` instead of the global. + - name: TransformStreamDefaultController + message: Use `const { TransformStreamDefaultController } = require('internal/webstreams/transformstream')` instead of the global. - name: URL message: Use `const { URL } = require('internal/url');` instead of the global. - name: URLSearchParams @@ -83,6 +111,12 @@ rules: # disabled with --jitless CLI flag. - name: WebAssembly message: Use `const { WebAssembly } = globalThis;` instead of the global. + - name: WritableStream + message: Use `const { WritableStream } = require('internal/webstreams/writablestream')` instead of the global. + - name: WritableStreamDefaultWriter + message: Use `const { WritableStreamDefaultWriter } = require('internal/webstreams/writablestream')` instead of the global. + - name: WritableStreamDefaultController + message: Use `const { WritableStreamDefaultController } = require('internal/webstreams/writablestream')` instead of the global. - name: atob message: Use `const { atob } = require('buffer');` instead of the global. - name: btoa diff --git a/lib/internal/blob.js b/lib/internal/blob.js index 19ba47f1752..68b8d6f89e2 100644 --- a/lib/internal/blob.js +++ b/lib/internal/blob.js @@ -88,6 +88,7 @@ function lazyURL(id) { } function lazyReadableStream(options) { + // eslint-disable-next-line no-global-assign ReadableStream ??= require('internal/webstreams/readablestream').ReadableStream; return new ReadableStream(options); diff --git a/lib/internal/bootstrap/browser.js b/lib/internal/bootstrap/browser.js index 68dac3b1ca4..49d69b93968 100644 --- a/lib/internal/bootstrap/browser.js +++ b/lib/internal/bootstrap/browser.js @@ -116,3 +116,57 @@ function defineReplacableAttribute(target, name, value) { value, }); } + +// Web Streams API +const { + TransformStream, + TransformStreamDefaultController, +} = require('internal/webstreams/transformstream'); + +const { + WritableStream, + WritableStreamDefaultController, + WritableStreamDefaultWriter, +} = require('internal/webstreams/writablestream'); + +const { + ReadableStream, + ReadableStreamDefaultReader, + ReadableStreamBYOBReader, + ReadableStreamBYOBRequest, + ReadableByteStreamController, + ReadableStreamDefaultController, +} = require('internal/webstreams/readablestream'); + +const { + ByteLengthQueuingStrategy, + CountQueuingStrategy, +} = require('internal/webstreams/queuingstrategies'); + +const { + TextEncoderStream, + TextDecoderStream, +} = require('internal/webstreams/encoding'); + +const { + CompressionStream, + DecompressionStream, +} = require('internal/webstreams/compression'); + +exposeInterface(globalThis, 'ReadableStream', ReadableStream); +exposeInterface(globalThis, 'ReadableStreamDefaultReader', ReadableStreamDefaultReader); +exposeInterface(globalThis, 'ReadableStreamBYOBReader', ReadableStreamBYOBReader); +exposeInterface(globalThis, 'ReadableStreamBYOBRequest', ReadableStreamBYOBRequest); +exposeInterface(globalThis, 'ReadableByteStreamController', ReadableByteStreamController); +exposeInterface(globalThis, 'ReadableStreamDefaultController', ReadableStreamDefaultController); +exposeInterface(globalThis, 'TransformStream', TransformStream); +exposeInterface(globalThis, 'TransformStreamDefaultController', TransformStreamDefaultController); +exposeInterface(globalThis, 'WritableStream', WritableStream); +exposeInterface(globalThis, 'WritableStreamDefaultWriter', WritableStreamDefaultWriter); +exposeInterface(globalThis, 'WritableStreamDefaultController', WritableStreamDefaultController); +exposeInterface(globalThis, 'ByteLengthQueuingStrategy', ByteLengthQueuingStrategy); +exposeInterface(globalThis, 'CountQueuingStrategy', CountQueuingStrategy); +exposeInterface(globalThis, 'TextEncoderStream', TextEncoderStream); +exposeInterface(globalThis, 'TextDecoderStream', TextDecoderStream); +exposeInterface(globalThis, 'CompressionStream', CompressionStream); +exposeInterface(globalThis, 'DecompressionStream', DecompressionStream); diff --git a/test/common/index.js b/test/common/index.js index b69d726e8ef..8aee3575837 100644 --- a/test/common/index.js +++ b/test/common/index.js @@ -309,6 +309,27 @@ if (hasCrypto && global.crypto) { knownGlobals.push(global.CryptoKey); knownGlobals.push(global.SubtleCrypto); } +if (global.ReadableStream) { + knownGlobals.push( + global.ReadableStream, + global.ReadableStreamDefaultReader, + global.ReadableStreamBYOBReader, + global.ReadableStreamBYOBRequest, + global.ReadableByteStreamController, + global.ReadableStreamDefaultController, + global.TransformStream, + global.TransformStreamDefaultController, + global.WritableStream, + global.WritableStreamDefaultWriter, + global.WritableStreamDefaultController, + global.ByteLengthQueuingStrategy, + global.CountQueuingStrategy, + global.TextEncoderStream, + global.TextDecoderStream, + global.CompressionStream, + global.DecompressionStream, + ); +} function allowGlobals(...allowlist) { knownGlobals = knownGlobals.concat(allowlist); diff --git a/test/parallel/test-bootstrap-modules.js b/test/parallel/test-bootstrap-modules.js index 04883cdf4cf..d5f69e8165f 100644 --- a/test/parallel/test-bootstrap-modules.js +++ b/test/parallel/test-bootstrap-modules.js @@ -140,8 +140,11 @@ const expectedModules = new Set([ 'NativeModule internal/validators', 'NativeModule internal/vm/module', 'NativeModule internal/webstreams/adapters', + 'NativeModule internal/webstreams/compression', + 'NativeModule internal/webstreams/encoding', 'NativeModule internal/webstreams/queuingstrategies', 'NativeModule internal/webstreams/readablestream', + 'NativeModule internal/webstreams/transformstream', 'NativeModule internal/webstreams/util', 'NativeModule internal/webstreams/writablestream', 'NativeModule internal/worker/io', diff --git a/test/parallel/test-global-webstreams.js b/test/parallel/test-global-webstreams.js new file mode 100644 index 00000000000..ab20e376b71 --- /dev/null +++ b/test/parallel/test-global-webstreams.js @@ -0,0 +1,24 @@ +'use strict'; + +require('../common'); + +const assert = require('assert'); +const webstreams = require('stream/web'); + +assert.strictEqual(ReadableStream, webstreams.ReadableStream); +assert.strictEqual(ReadableStreamDefaultReader, webstreams.ReadableStreamDefaultReader); +assert.strictEqual(ReadableStreamBYOBReader, webstreams.ReadableStreamBYOBReader); +assert.strictEqual(ReadableStreamBYOBRequest, webstreams.ReadableStreamBYOBRequest); +assert.strictEqual(ReadableByteStreamController, webstreams.ReadableByteStreamController); +assert.strictEqual(ReadableStreamDefaultController, webstreams.ReadableStreamDefaultController); +assert.strictEqual(TransformStream, webstreams.TransformStream); +assert.strictEqual(TransformStreamDefaultController, webstreams.TransformStreamDefaultController); +assert.strictEqual(WritableStream, webstreams.WritableStream); +assert.strictEqual(WritableStreamDefaultWriter, webstreams.WritableStreamDefaultWriter); +assert.strictEqual(WritableStreamDefaultController, webstreams.WritableStreamDefaultController); +assert.strictEqual(ByteLengthQueuingStrategy, webstreams.ByteLengthQueuingStrategy); +assert.strictEqual(CountQueuingStrategy, webstreams.CountQueuingStrategy); +assert.strictEqual(TextEncoderStream, webstreams.TextEncoderStream); +assert.strictEqual(TextDecoderStream, webstreams.TextDecoderStream); +assert.strictEqual(CompressionStream, webstreams.CompressionStream); +assert.strictEqual(DecompressionStream, webstreams.DecompressionStream); diff --git a/test/wpt/test-streams.js b/test/wpt/test-streams.js index 987676d8c49..43c212247c4 100644 --- a/test/wpt/test-streams.js +++ b/test/wpt/test-streams.js @@ -5,112 +5,8 @@ const { WPTRunner } = require('../common/wpt'); const runner = new WPTRunner('streams'); -// Set Node.js flags required for the tests. -runner.setFlags(['--expose-internals']); - // Set a script that will be executed in the worker before running the tests. runner.setInitScript(` - let { - ReadableStream, - ReadableStreamDefaultReader, - ReadableStreamBYOBReader, - ReadableStreamBYOBRequest, - ReadableByteStreamController, - ReadableStreamDefaultController, - TransformStream, - TransformStreamDefaultController, - WritableStream, - WritableStreamDefaultWriter, - WritableStreamDefaultController, - ByteLengthQueuingStrategy, - CountQueuingStrategy, - } = require('stream/web'); - - const { internalBinding } = require('internal/test/binding'); - const { DOMException } = internalBinding('messaging'); - global.DOMException = DOMException; - - Object.defineProperties(global, { - ReadableStream: { - value: ReadableStream, - configurable: true, - writable: true, - enumerable: false, - }, - ReadableStreamDefaultReader: { - value: ReadableStreamDefaultReader, - configurable: true, - writable: true, - enumerable: false, - }, - ReadableStreamBYOBReader: { - value: ReadableStreamBYOBReader, - configurable: true, - writable: true, - enumerable: false, - }, - ReadableStreamBYOBRequest: { - value: ReadableStreamBYOBRequest, - configurable: true, - writable: true, - enumerable: false, - }, - ReadableByteStreamController: { - value: ReadableByteStreamController, - configurable: true, - writable: true, - enumerable: false, - }, - ReadableStreamDefaultController: { - value: ReadableStreamDefaultController, - configurable: true, - writable: true, - enumerable: false, - }, - TransformStream: { - value: TransformStream, - configurable: true, - writable: true, - enumerable: false, - }, - TransformStreamDefaultController: { - value: TransformStreamDefaultController, - configurable: true, - writable: true, - enumerable: false, - }, - WritableStream: { - value: WritableStream, - configurable: true, - writable: true, - enumerable: false, - }, - WritableStreamDefaultWriter: { - value: WritableStreamDefaultWriter, - configurable: true, - writable: true, - enumerable: false, - }, - WritableStreamDefaultController: { - value: WritableStreamDefaultController, - configurable: true, - writable: true, - enumerable: false, - }, - ByteLengthQueuingStrategy: { - value: ByteLengthQueuingStrategy, - configurable: true, - writable: true, - enumerable: false, - }, - CountQueuingStrategy: { - value: CountQueuingStrategy, - configurable: true, - writable: true, - enumerable: false, - }, - }); - // Simulate global postMessage for enqueue-with-detached-buffer.window.js function postMessage(value, origin, transferList) { const mc = new MessageChannel(); |