stream: remove duplicated utility

Signed-off-by: Antoine du Hamel <[email protected]>

Author: aduh95

lib/internal/webstreams/queuingstrategies.js

@@ -19,6 +19,7 @@ const {
 
 const {
   customInspect,
+  getNonWritablePropertyDescriptor,
 } = require('internal/webstreams/util');
 
 const {
@@ -46,14 +47,6 @@ const byteSizeFunction = ObjectDefineProperty(
 );
 const countSizeFunction = ObjectDefineProperty(() => 1, 'name', nameDescriptor);
 
-const getNonWritablePropertyDescriptor = (value) => {
-  return {
-    __proto__: null,
-    configurable: true,
-    value,
-  };
-};
-
 /**
  * @type {QueuingStrategy}
  */

lib/internal/webstreams/readablestream.js

@@ -106,15 +106,16 @@ const {
   enqueueValueWithSize,
   extractHighWaterMark,
   extractSizeAlgorithm,
-  lazyTransfer,
+  getNonWritablePropertyDescriptor,
   isBrandCheck,
-  resetQueue,
-  setPromiseHandled,
+  kState,
+  kType,
+  lazyTransfer,
   nonOpCancel,
   nonOpPull,
   nonOpStart,
-  kType,
-  kState,
+  resetQueue,
+  setPromiseHandled,
 } = require('internal/webstreams/util');
 
 const {
@@ -171,14 +172,6 @@ function lazyReadableReleasingError() {
   return releasingError;
 }
 
-const getNonWritablePropertyDescriptor = (value) => {
-  return {
-    __proto__: null,
-    configurable: true,
-    value,
-  };
-};
-
 /**
  * @typedef {import('../abort_controller').AbortSignal} AbortSignal
  * @typedef {import('./queuingstrategies').QueuingStrategy} QueuingStrategy

lib/internal/webstreams/transformstream.js

@@ -47,11 +47,12 @@ const {
   customInspect,
   extractHighWaterMark,
   extractSizeAlgorithm,
+  getNonWritablePropertyDescriptor,
   isBrandCheck,
-  nonOpFlush,
-  kType,
   kState,
+  kType,
   nonOpCancel,
+  nonOpFlush,
 } = require('internal/webstreams/util');
 
 const {
@@ -72,13 +73,6 @@ const {
 const assert = require('internal/assert');
 
 const kSkipThrow = Symbol('kSkipThrow');
-const getNonWritablePropertyDescriptor = (value) => {
-  return {
-    __proto__: null,
-    configurable: true,
-    value,
-  };
-};
 
 /**
  * @typedef {import('./queuingstrategies').QueuingStrategy

lib/internal/webstreams/util.js

@@ -52,6 +52,14 @@ const AsyncIterator = {
   return: undefined,
 };
 
+const getNonWritablePropertyDescriptor = (value) => {
+  return {
+    __proto__: null,
+    configurable: true,
+    value,
+  };
+};
+
 function extractHighWaterMark(value, defaultHWM) {
   if (value === undefined) return defaultHWM;
   value = +value;
@@ -204,25 +212,26 @@ module.exports = {
   ArrayBufferViewGetByteOffset,
   AsyncIterator,
   canCopyArrayBuffer,
-  createPromiseCallback,
   cloneAsUint8Array,
   copyArrayBuffer,
+  createPromiseCallback,
   customInspect,
   dequeueValue,
   enqueueValueWithSize,
   extractHighWaterMark,
   extractSizeAlgorithm,
-  lazyTransfer,
+  getNonWritablePropertyDescriptor,
   isBrandCheck,
   isPromisePending,
-  peekQueueValue,
-  resetQueue,
-  setPromiseHandled,
+  kState,
+  kType,
+  lazyTransfer,
   nonOpCancel,
   nonOpFlush,
   nonOpPull,
   nonOpStart,
   nonOpWrite,
-  kType,
-  kState,
+  peekQueueValue,
+  resetQueue,
+  setPromiseHandled,
 };

lib/internal/webstreams/writablestream.js

@@ -61,17 +61,18 @@ const {
   enqueueValueWithSize,
   extractHighWaterMark,
   extractSizeAlgorithm,
-  lazyTransfer,
+  getNonWritablePropertyDescriptor,
   isBrandCheck,
   isPromisePending,
-  peekQueueValue,
-  resetQueue,
-  setPromiseHandled,
+  kState,
+  kType,
+  lazyTransfer,
   nonOpCancel,
   nonOpStart,
   nonOpWrite,
-  kType,
-  kState,
+  peekQueueValue,
+  resetQueue,
+  setPromiseHandled,
 } = require('internal/webstreams/util');
 
 const {
@@ -106,14 +107,6 @@ function lazyWritableReleasedError() {
   return releasedError;
 }
 
-const getNonWritablePropertyDescriptor = (value) => {
-  return {
-    __proto__: null,
-    configurable: true,
-    value,
-  };
-};
-
 /**
  * @typedef {import('../abort_controller').AbortSignal} AbortSignal
  * @typedef {import('./queuingstrategies').QueuingStrategy