stream: wip

Author: rluvaton

lib/internal/webstreams/readablestream.js

@@ -140,6 +140,7 @@ const kChunk = Symbol('kChunk');
 const kError = Symbol('kError');
 const kPull = Symbol('kPull');
 const kRelease = Symbol('kRelease');
+const kSkipThrow = Symbol('kSkipThrow');
 
 let releasedError;
 let releasingError;
@@ -1019,8 +1020,8 @@ ObjectDefineProperties(ReadableStreamBYOBReader.prototype, {
 class ReadableStreamDefaultController {
   [kType] = 'ReadableStreamDefaultController';
 
-  constructor() {
-    if (new.target === ReadableStreamDefaultController) {
+  constructor(skipThrowSymbol) {
+    if (new.target === ReadableStreamDefaultController || skipThrowSymbol !== kSkipThrow) {
       throw new ERR_ILLEGAL_CONSTRUCTOR();
     }
   }
@@ -1079,8 +1080,8 @@ ObjectDefineProperties(ReadableStreamDefaultController.prototype, {
 });
 
 class ReadableStreamDefaultControllerClazz extends ReadableStreamDefaultController {
-  constructor() {
-    super();
+  constructor(skipThrowSymbol) {
+    super(skipThrowSymbol);
     this[kType] = 'ReadableStreamDefaultController';
     this[kState] = {};
   }
@@ -2414,7 +2415,7 @@ function setupReadableStreamDefaultControllerFromSource(
   source,
   highWaterMark,
   sizeAlgorithm) {
-  const controller = new ReadableStreamDefaultControllerClazz();
+  const controller = new ReadableStreamDefaultControllerClazz(kSkipThrow);
   const start = source?.start;
   const pull = source?.pull;
   const cancel = source?.cancel;

lib/internal/webstreams/transformstream.js

@@ -65,6 +65,8 @@ const {
 
 const assert = require('internal/assert');
 
+const kSkipThrow = Symbol('kSkipThrow');
+
 const getNonWritablePropertyDescriptor = (value) => {
   return {
     __proto__: null,
@@ -268,8 +270,8 @@ TransferredTransformStream.prototype[kDeserialize] = () => {};
 class TransformStreamDefaultController {
   [kType] = 'TransformStreamDefaultController';
 
-  constructor() {
-    if (new.target === TransformStreamDefaultController) {
+  constructor(skipThrowSymbol) {
+    if (skipThrowSymbol !== kSkipThrow) {
       throw new ERR_ILLEGAL_CONSTRUCTOR();
     }
   }
@@ -333,8 +335,8 @@ ObjectDefineProperties(TransformStreamDefaultController.prototype, {
 });
 
 class TransformStreamDefaultControllerClazz extends TransformStreamDefaultController {
-  constructor() {
-    super();
+  constructor(skipThrowSymbol) {
+    super(skipThrowSymbol);
     this[kType] = 'TransformStreamDefaultController';
   }
 }
@@ -453,7 +455,7 @@ function setupTransformStreamDefaultController(
 function setupTransformStreamDefaultControllerFromTransformer(
   stream,
   transformer) {
-  const controller = new TransformStreamDefaultControllerClazz();
+  const controller = new TransformStreamDefaultControllerClazz(kSkipThrow);
   const transform = transformer?.transform || defaultTransformAlgorithm;
   const flush = transformer?.flush || nonOpFlush;
   const transformAlgorithm =

lib/internal/webstreams/writablestream.js

@@ -81,6 +81,7 @@ const assert = require('internal/assert');
 const kAbort = Symbol('kAbort');
 const kCloseSentinel = Symbol('kCloseSentinel');
 const kError = Symbol('kError');
+const kSkipThrow = Symbol('kSkipThrow');
 
 let releasedError;
 
@@ -522,8 +523,8 @@ ObjectDefineProperties(WritableStreamDefaultWriter.prototype, {
 class WritableStreamDefaultController {
   [kType] = 'WritableStreamDefaultController';
 
-  constructor() {
-    if (new.target === WritableStreamDefaultController) {
+  constructor(skipThrowSymbol) {
+    if (new.target === WritableStreamDefaultController || skipThrowSymbol !== kSkipThrow) {
       throw new ERR_ILLEGAL_CONSTRUCTOR();
     }
   }
@@ -572,8 +573,8 @@ ObjectDefineProperties(WritableStreamDefaultController.prototype, {
 });
 
 class WritableStreamDefaultControllerClazz extends WritableStreamDefaultController {
-  constructor() {
-    super();
+  constructor(skipThrowSymbol) {
+    super(skipThrowSymbol);
     this[kType] = 'WritableStreamDefaultController';
   }
 }
@@ -1234,7 +1235,7 @@ function setupWritableStreamDefaultControllerFromSink(
   sink,
   highWaterMark,
   sizeAlgorithm) {
-  const controller = new WritableStreamDefaultControllerClazz();
+  const controller = new WritableStreamDefaultControllerClazz(kSkipThrow);
   const start = sink?.start;
   const write = sink?.write;
   const close = sink?.close;