lib: reuse invalid state errors on webstreams

Signed-off-by: RafaelGSS <[email protected]>

Author: RafaelGSS

lib/internal/webstreams/readablestream.js

@@ -37,6 +37,7 @@ const {
     ERR_INVALID_STATE,
     ERR_INVALID_THIS,
   },
+  hideStackFrames,
 } = require('internal/errors');
 
 const {
@@ -140,6 +141,25 @@ const kError = Symbol('kError');
 const kPull = Symbol('kPull');
 const kRelease = Symbol('kRelease');
 
+let releasedError;
+let releasingError;
+
+const lazyReadableReleasedError = hideStackFrames(() => {
+  releasedError ??= new ERR_INVALID_STATE.TypeError('Reader released');
+  // Avoid V8 leak
+  // eslint-disable-next-line no-unused-expressions
+  releasedError.stack;
+  return releasedError;
+});
+
+const lazyReadableReleasingError = hideStackFrames(() => {
+  releasingError ??= new ERR_INVALID_STATE.TypeError('Releasing reader');
+  // Avoid V8 leak
+  // eslint-disable-next-line no-unused-expressions
+  releasingError.stack;
+  return releasingError;
+});
+
 const getNonWritablePropertyDescriptor = (value) => {
   return {
     __proto__: null,
@@ -2029,7 +2049,7 @@ function readableStreamDefaultReaderRelease(reader) {
   readableStreamReaderGenericRelease(reader);
   readableStreamDefaultReaderErrorReadRequests(
     reader,
-    new ERR_INVALID_STATE.TypeError('Releasing reader')
+    lazyReadableReleasingError(),
   );
 }
 
@@ -2044,7 +2064,7 @@ function readableStreamBYOBReaderRelease(reader) {
   readableStreamReaderGenericRelease(reader);
   readableStreamBYOBReaderErrorReadIntoRequests(
     reader,
-    new ERR_INVALID_STATE.TypeError('Releasing reader')
+    lazyReadableReleasingError(),
   );
 }
 
@@ -2062,13 +2082,12 @@ function readableStreamReaderGenericRelease(reader) {
   assert(stream !== undefined);
   assert(stream[kState].reader === reader);
 
+  const releasedStateError = lazyReadableReleasedError();
   if (stream[kState].state === 'readable') {
-    reader[kState].close.reject?.(
-      new ERR_INVALID_STATE.TypeError('Reader released'));
+    reader[kState].close.reject?.(releasedStateError);
   } else {
     reader[kState].close = {
-      promise: PromiseReject(
-        new ERR_INVALID_STATE.TypeError('Reader released')),
+      promise: PromiseReject(releasedStateError),
       resolve: undefined,
       reject: undefined,
     };

lib/internal/webstreams/writablestream.js

@@ -24,6 +24,7 @@ const {
     ERR_INVALID_STATE,
     ERR_INVALID_THIS,
   },
+  hideStackFrames,
 } = require('internal/errors');
 
 const {
@@ -77,6 +78,16 @@ const kAbort = Symbol('kAbort');
 const kCloseSentinel = Symbol('kCloseSentinel');
 const kError = Symbol('kError');
 
+let releasedError;
+
+const lazyWritableReleasedError = hideStackFrames(() => {
+  releasedError ??= new ERR_INVALID_STATE.TypeError('Writer has been released');
+  // Avoid V8 leak
+  // eslint-disable-next-line no-unused-expressions
+  releasedError.stack;
+  return releasedError;
+});
+
 const getNonWritablePropertyDescriptor = (value) => {
   return {
     __proto__: null,
@@ -970,10 +981,9 @@ function writableStreamDefaultWriterRelease(writer) {
   } = writer[kState];
   assert(stream !== undefined);
   assert(stream[kState].writer === writer);
-  const releasedError =
-    new ERR_INVALID_STATE.TypeError('Writer has been released');
-  writableStreamDefaultWriterEnsureReadyPromiseRejected(writer, releasedError);
-  writableStreamDefaultWriterEnsureClosedPromiseRejected(writer, releasedError);
+  const releasedStateError = lazyWritableReleasedError();
+  writableStreamDefaultWriterEnsureReadyPromiseRejected(writer, releasedStateError);
+  writableStreamDefaultWriterEnsureClosedPromiseRejected(writer, releasedStateError);
   stream[kState].writer = undefined;
   writer[kState].stream = undefined;
 }