stream: cleanup

nodejs · Aug 10, 2023 · 4bb72eb · 4bb72eb
1 parent 9cfa60d
commit 4bb72eb
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 12 deletions.
diff --git a/lib/internal/webstreams/readablestream.js b/lib/internal/webstreams/readablestream.js
@@ -1019,6 +1019,7 @@ ObjectDefineProperties(ReadableStreamBYOBReader.prototype, {
 
 class ReadableStreamDefaultController {
   [kType] = 'ReadableStreamDefaultController';
+  [kState] = {};
 
   constructor(skipThrowSymbol) {
     if (skipThrowSymbol !== kSkipThrow) {
@@ -1080,12 +1081,7 @@ ObjectDefineProperties(ReadableStreamDefaultController.prototype, {
 });
 
 function createReadableStreamDefaultController() {
-  const controller = new ReadableStreamDefaultController(kSkipThrow);
-
-  controller[kType] = 'ReadableStreamDefaultController';
-  controller[kState] = {};
-
-  return controller;
+  return new ReadableStreamDefaultController(kSkipThrow);
 }
 
 class ReadableByteStreamController {

diff --git a/lib/internal/webstreams/transformstream.js b/lib/internal/webstreams/transformstream.js
@@ -336,9 +336,7 @@ ObjectDefineProperties(TransformStreamDefaultController.prototype, {
 });
 
 function createTransformStreamDefaultController() {
-  const controller = new TransformStreamDefaultController(kSkipThrow);
-  controller[kType] = 'TransformStreamDefaultController';
-  return controller;
+  return new TransformStreamDefaultController(kSkipThrow);
 }
 
 const isTransformStream =

diff --git a/lib/internal/webstreams/writablestream.js b/lib/internal/webstreams/writablestream.js
@@ -573,9 +573,7 @@ ObjectDefineProperties(WritableStreamDefaultController.prototype, {
 });
 
 function createWritableStreamDefaultController() {
-  const controller = new WritableStreamDefaultController(kSkipThrow);
-  controller[kType] = 'WritableStreamDefaultController';
-  return controller;
+  return new WritableStreamDefaultController(kSkipThrow);
 }
 
 const isWritableStream =